目录
1.通过kafka向zk发送命令让它创建一个无状态topic
2.查看当前zk中所有主题topic
3.发送消息
4.消费消息
案例：
单播消息和多播消息
单播消息
那么不同消费组的能否消费同topic的消息呢？
多播消息
查看消费者信息
(42条消息) 【kafka系列】kafka之生产者发送消息实践_溪~源的博客-CSDN博客_kafka生产者发送消息命令
1.通过kafka向zk发送命令让它创建一个无状态topic
bin/kafka-topics.sh --bootstrap-server 82.157.198.247:9092 --create --partitions
2.查看当前zk中所有主题topic
bin/kafka-topics.sh --bootstrap-server 82.157.198.247:9092 --describe --topic test
3.发送消息
把消息发送给broker中的某个topic
我们可以直接在命令行中输入内容，将消息发送到Kafka中，每一行会被当做一个独立的消息；使用kafka的发送消息客户端——>发送到指定的kafka服务器地址和topic主题
bin/kafka-console-producer.sh --broker-list 82.157.198.247:9092 --topic test
我们每发一条信息，都会发送到指定的kafka服务器上 ，那么具体保存在哪呢？就是日志文件下：主题-标识id分区下的0000.log
4.消费消息
1.从最后一条消息+1开始消费
bin/kafka-console-consumer.sh --bootstrap-server 82.157.198.247:9092 --topic test
案例：
上面也讲了消息的发送者将消息发送到oooo.log中，并且按照偏移量排序（描述消息的有序性)，所以消费者去当中进行消费
2.从头开始消费
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic test
本质就是一个发布订阅，我们来看看日志文件看看是如何消费的
蓝色的是消费者的消费偏移量，然后还有个test-0存放当前topic节点的信息
进入test-0（topic主题-标识id）
单播消息和多播消息
单播消息
概念：一个消费组里面只能有一个消费者订阅到topic的消息
在kafka的topic中启动两个消费者，一个生产者，消费者是否都会收到？
1.在kafka服务器broker后配置服务组 --consumer -property.id=xxx
bin/kafka-console-consumer.sh --bootstrap-server 82.157.198.247:9092 --consumer-property group.id=testGroup --topic test
2.利用消费组组开启一个消费组消费消息，发现消费者接收到了消息（利用消费组）
3.再开启一个消费者（消费组中），发现这个消费者消费不了服务方发来的消息
4. 但是如果一个消费者一个不在同消费组可以一起消费同一个topic的消息
那么不同消费组的能否消费同topic的消息呢？
是可以的，也就是我们的多播消息，不同消费组订阅同一个topic
bin/kafka-console-consumer.sh --bootstrap-server 82.157.198.247:9092 --consumer-property group.id=testGroup1 --topic test
消费组TestGroup1
消费组TestGroup
多播消息
不同消费组的消费者能够订阅同一个topic的消息，单播消息和多播消息也可以综合起来考虑，比如testGroup1有两个消费者，testGroup2有两个消费者——>各有一个能够消费topic中的消息
查看消费者信息
1.查看当前主题下有多少消费者订阅
bin/kafka-consumer-groups.sh --bootstrap-server 82.157.198.247:9092 --list
2.查看消费组的详细信息
当前消费到的位置偏移量，已经消费完的偏移量，和剩余的消息数量（查看消费组的详细信息）
bin/kafka-consumer-groups.sh --bootstrap-server 82.157.198.247:9092 --describe --group testGroup
