ISIS-specific Kafka tools. Deserialises the ESS flatbuffers blobs from Kafka.
Also allows replaying data in a topic.
To run the latest version, install uv and use uvx saluki <args>.
alternatively you can pip install saluki and run it from a venv.
See saluki --help for all options.
saluki listen mybroker:9092/mytopic - This will listen for updates for mytopic on mybroker.
saluki listen mybroker:9092/mytopic -f f144 -f f142 - This will listen for updates but ignore messages with schema IDs of f142 or f144
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.
Use the -g flag to go the other way, ie. in the above example to consume the 9 messages after offset 123456
You can also filter out messages to specific schema(s) with the -f flag, like the example above for listen.
saluki sniff mybroker:9092
Output looks as follows:
$ saluki sniff mybroker:9092
INFO:saluki:Cluster ID: redpanda.0faa4595-7298-407e-9db7-7e2758d1af1f
INFO:saluki:Brokers:
INFO:saluki: 192.168.0.111:9092/1
INFO:saluki: 192.168.0.112:9092/2
INFO:saluki: 192.168.0.113:9092/0
INFO:saluki:Topics:
INFO:saluki: MERLIN_events:
INFO:saluki: 0 - low:262322729, high:302663378, num_messages:40340649
INFO:saluki: MERLIN_runInfo:
INFO:saluki: 0 - low:335, high:2516, num_messages:2181
INFO:saluki: MERLIN_monitorHistograms:
INFO:saluki: 0 - low:7515, high:7551, num_messages:36
saluki play mybroker:9092/source_topic mybroker:9092/dest_topic -o 123 125 - This will forward messages at offset 123, 124 and 125 in the source_topic to the dest_topic
saluki play mybroker:9092/source_topic mybroker:9092/dest_topic -t 1762209990 1762209992 - This will forward messages between the two given timestamps.
pip install -e .[dev]