We use the reference topic named test
, and the consumer group piero-group
. Zookeeper runs on localhost:9092
, Kafka bootstrap server is localhost:2181
-
Create a topic named
test
with 4 partitions, without replication~/tools/kafka_2.11-1.1.0/bin/kafka-topics.sh --create --zookeeper localhost:2181 --partitions 4 --replication-factor 1 --topic test4
-
Produce String messages from console and post them on topic