Instantly share code, notes, and snippets.

Embed
What would you like to do?
/usr/local/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
Test Message 1
Test Message 2
# ^D
# Test
/usr/local/kafka/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
# Test Message 1
# Test Message 2
# ^C
# Consumed 2 messages
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment