Skip to content

Commit 5f9f639

Browse files
authored
Merge pull request #281 from jackcipher/jack/20231007_docs_update
feature: add more usage example
2 parents 4013054 + 8103a02 commit 5f9f639

File tree

1 file changed

+12
-0
lines changed

1 file changed

+12
-0
lines changed

README.md

+12
Original file line numberDiff line numberDiff line change
@@ -60,6 +60,8 @@ Describe a given topic called _mqtt.messages.incoming_
6060

6161
`kaf topic describe mqtt.messages.incoming`
6262

63+
### Group Inspection
64+
6365
List consumer groups
6466

6567
`kaf groups`
@@ -72,10 +74,20 @@ Write message into given topic from stdin
7274

7375
`echo test | kaf produce mqtt.messages.incoming`
7476

77+
### Offset Reset
78+
7579
Set offset for consumer group _dispatcher_ consuming from topic _mqtt.messages.incoming_ to latest for all partitions
7680

7781
`kaf group commit dispatcher -t mqtt.messages.incoming --offset latest --all-partitions`
7882

83+
Set offset to oldest
84+
85+
`kaf group commit dispatcher -t mqtt.messages.incoming --offset oldest --all-partitions`
86+
87+
Set offset to 1001 for partition 0
88+
89+
`kaf group commit dispatcher -t mqtt.messages.incoming --offset 1001 --partition 0`
90+
7991
## Configuration
8092
See the [examples](examples) folder
8193

0 commit comments

Comments
 (0)