watcher

Install LocalTerra:

git clone git@github.com:terra-money/LocalTerra.git
cd LocalTerra
docker compose up

Clone the watcher repo and start the pulsar and pulsar-manager containers

git@github.com:tuky191/watcher.git
cd watcher
docker compose up -d

Create tenant: terra, namespace: localterra

docker exec -it pulsar /pulsar/bin/pulsar-admin tenants create terra
docker exec -it pulsar /pulsar/bin/pulsar-admin namespaces create terra/localterra

Set retention policy to infinite for the localterra namespace:

docker exec -it pulsar /pulsar/bin/pulsar-admin namespaces set-retention terra/localterra --time -1 --size -1

Optional, setup the pulsar-manager and add the terra tenant:

Service URL
http://pulsar:8080
Bookie URL
http://pulsar:6650

CSRF_TOKEN=$(curl http://backend-service:7750/pulsar-manager/csrf-token)
curl \
    -H "X-XSRF-TOKEN: $CSRF_TOKEN" \
    -H "Cookie: XSRF-TOKEN=$CSRF_TOKEN;" \
    -H 'Content-Type: application/json' \
    -X PUT http://backend-service:7750/pulsar-manager/users/superuser \
    -d '{"name": "admin", "password": "apachepulsar", "description": "test", "email": "username@test.org"}'

Run the rpcwatcher:

go run cmd/rpcwatcher/main.go

Open new terminal:

python3 consumer.py