Skip to content

Commit

Permalink
Merge pull request #281 from jackcipher/jack/20231007_docs_update
Browse files Browse the repository at this point in the history
feature: add more usage example
  • Loading branch information
birdayz authored Oct 19, 2023
2 parents 4013054 + 8103a02 commit 5f9f639
Showing 1 changed file with 12 additions and 0 deletions.
12 changes: 12 additions & 0 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -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`
Expand All @@ -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

Expand Down

0 comments on commit 5f9f639

Please sign in to comment.