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