kcat - kafkacat

send/submit messages from a file in bulk

file.json contiene una lista de mensajes en formato JSON, uno por línea.

kcat -F ~/.config/kafkacat-pro.conf -t my-topic.migration -T -P -l file.json

consume messages from a topic from timestamp

donde -o beginning indica que se deben consumir todos los mensajes desde el timestamp 1751288400000. https://www.epochconverter.com/

kcat -F ~/.config/kafkacat-pro.conf -C -t my-topic.migration -o beginning -e

kcat -F ~/.config/kafkacat-pro.conf -C-t my-topic.migration -o s@1751288400000 -e | grep "whatever.com" | jq -r '.id'

kcat -F ~/.config/kafkacat-pro.conf -C-t my-topic.migration -o s@1751288400000 -e | grep \"id\" | jq -r '.id'