File tree 1 file changed +12
-0
lines changed
1 file changed +12
-0
lines changed Original file line number Diff line number Diff line change @@ -60,6 +60,8 @@ Describe a given topic called _mqtt.messages.incoming_
60
60
61
61
` kaf topic describe mqtt.messages.incoming `
62
62
63
+ ### Group Inspection
64
+
63
65
List consumer groups
64
66
65
67
` kaf groups `
@@ -72,10 +74,20 @@ Write message into given topic from stdin
72
74
73
75
` echo test | kaf produce mqtt.messages.incoming `
74
76
77
+ ### Offset Reset
78
+
75
79
Set offset for consumer group _ dispatcher_ consuming from topic _ mqtt.messages.incoming_ to latest for all partitions
76
80
77
81
` kaf group commit dispatcher -t mqtt.messages.incoming --offset latest --all-partitions `
78
82
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
+
79
91
## Configuration
80
92
See the [ examples] ( examples ) folder
81
93
You can’t perform that action at this time.
0 commit comments