Skip to content

Instantly share code, notes, and snippets.

@marceloserpa

marceloserpa/kafka-partitions-poc.md

Created November 29, 2020 23:08
Show Gist options
  • Save marceloserpa/9465ae2ec5c41d3eb72f541197cbddc3 to your computer and use it in GitHub Desktop.
Save marceloserpa/9465ae2ec5c41d3eb72f541197cbddc3 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
kafka-partitions-poc.md

bin/kafka-topics.sh --create --topic car-sales --bootstrap-server localhost:9092 --replication-factor 1 --partitions 2

bin/kafka-console-producer.sh --topic car-sales --broker-list localhost:9092 --property parse.key=true --property key.separator=":"

bin/kafka-console-consumer.sh --topic car-sales --bootstrap-server localhost:9092 --from-beginning --property print.key=true --property key.separator="-" --partition 0

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment