kafka最新版创建命令


	
./kafka-topics.sh --create --partitions 1 --replication-factor 1 --topic quickstart-events --bootstrap-server localhost:9092
./kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092
./kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
./kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
查看消费者组
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
查看消费者组的消费者详情
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group console-consumer-68557

当生产者发送“如果帅有罪” 消费者消费的是上一个offset+1的即7+1的偏移量数据

当生产者发送“请把我埋葬” 消费者消费的是上一个offset+1的即8+1的偏移量的数据

重启消费者命令:
/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning