Mini toolkit for any development tools
Install the package with the following command:
go install github.com/suryatresna/devkit@latestProduce Message
devkit kafka produce --brokers 127.0.0.1:19092 --topic topic.foo.bar --jsonfile tmp/testjson.jsonManual Commit
devkit kafka commit --brokers localhost:9092 --group my-group --topic my-topic --poll 1Reset Offset
devkit kafka offset --brokers localhost:9092 --group my-group --topic my-topic --offset 0 --datetime "3/19/2025, 12:06:37"- offset 0 will use datetime as offset, if datetime not set, that will use default date
time.Now() - offset 1 will use beginning of offset
- offset -1 will use end of offset
devkit gocraft worker --redis 127.0.0.1:6379 --ns fooworker --job foojob --json '{"myid":1234}'- Client consuming
- Create Topic
- Delete Topic