Skip to content

Instantly share code, notes, and snippets.

What would you like to do?
bin/ \
--topic topicA \
--bootstrap-server $BOOTSTRAP_SERVER \
--producer.config config/
# copy and paste contents of 'sales_messages.txt' and then Ctrl+C to exit
# check for messages in topic
bin/ \
--topic topicA \
--from-beginning --max-messages 5 \
--property print.value=true \
--property print.offset=true \
--property print.partition=true \
--property print.timestamp=true \
--bootstrap-server $BOOTSTRAP_SERVER \
--consumer.config config/
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment