You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: README.md
+11-3Lines changed: 11 additions & 3 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -4,11 +4,19 @@ Serialise/deserialise flatbuffers blobs from kafka.
4
4
This currently deserialises https://github.com/ess-dmsc/python-streaming-data-types, but I am working to make it agnostic. Python bindings for the respective schema will need to be generated.
5
5
6
6
# Usage
7
-
`saluki --help`
7
+
See `saluki --help` for all options.
8
8
9
-
# install
9
+
## Listen to a topic for updates
10
+
`saluki listen mybroker:9092/mytopic` - This will listen for updates for `mytopic` on `mybroker`.
11
+
12
+
## Consume from a topic
13
+
`saluki consume mybroker:9092/mytopic -p 1 -o 123456 -m 10` - This will print 9 messages before (and inclusively the offset specified) offset `123456` of `mytopic` on `mybroker`, in partition 1.
14
+
15
+
Use the `-g` flag to go the other way, ie. in the above example to consume 9 messages FROM offset 123456
0 commit comments