From 8103a02f026761bb51b7ba7d1012da26b960d5af Mon Sep 17 00:00:00 2001 From: jackcipher Date: Sat, 7 Oct 2023 09:32:16 +0800 Subject: [PATCH] feature: add more usage example --- README.md | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/README.md b/README.md index 4aaa5527..8a89b8a9 100644 --- a/README.md +++ b/README.md @@ -60,6 +60,8 @@ Describe a given topic called _mqtt.messages.incoming_ `kaf topic describe mqtt.messages.incoming` +### Group Inspection + List consumer groups `kaf groups` @@ -72,10 +74,20 @@ Write message into given topic from stdin `echo test | kaf produce mqtt.messages.incoming` +### Offset Reset + Set offset for consumer group _dispatcher_ consuming from topic _mqtt.messages.incoming_ to latest for all partitions `kaf group commit dispatcher -t mqtt.messages.incoming --offset latest --all-partitions` +Set offset to oldest + +`kaf group commit dispatcher -t mqtt.messages.incoming --offset oldest --all-partitions` + +Set offset to 1001 for partition 0 + +`kaf group commit dispatcher -t mqtt.messages.incoming --offset 1001 --partition 0` + ## Configuration See the [examples](examples) folder