consumer.properties
group.id=group1
./kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic test
./kafka-console-producer.sh --broker-list kafka:9092 --topic test
./kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic test --consumer.config ./consumer.properties
./kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic test --consumer.config ./consumer.properties
- 1,a 1,b 1,c
- 1,a 1,b 1,c
./kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 2 --topic test1
./kafka-console-producer.sh --broker-list kafka:9092 --topic test1
./kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic test1 --consumer.config ./consumer.properties
./kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic test1 --consumer.config ./consumer.properties
- 1,a 1,b 1,c 1,d
- 1,a 1,c
- 1,b 1,d
consumer1.properties
group.id=group2
./kafka-console-producer.sh --broker-list kafka:9092 --topic test1
./kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic test1 --consumer.config ./consumer.properties
./kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic test1 --consumer.config ./consumer1.properties
- 1,a 1,b 1,c 1,d
- 1,a 1,b 1,c 1,d
- 1,a 1,b 1,c 1,d
./kafka-topics.sh --alter --zookeeper zookeeper:2181 --partitions 3 --topic test
./kafka-console-producer.sh --broker-list kafka:9092 --topic test
./kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic test --consumer.config ./consumer.properties
./kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic test --consumer.config ./consumer.properties
- 1,a 1,b 1,c 1,d 1,e 1,f
- 1,a 1,c 1,d 1,f
- 1,b 1,e