kcat

brew install kcat jq

consume message

kcat -b localhost:9092 -t topic -C -o end -u | jq

produce message

echo '{"id":"b611c338-1e11-11ed-b5ce-461e464ebed9","chatId":"2d1bb2b4-1e11-11ed-9c9f-461e464ebed9","body":"Please help me!","fromClient":true}' | kcat -b localhost:9092 -t chat.messages -P

kafka

task up

task down