06、Kafka：单播和多播消息的实现

### **单播和多播消息的实现**

------------

**单播消息**

在⼀个kafka的topic中，启动两个消费者，⼀个⽣产者，问：⽣产者发送消息，这条消息是否同时会被两个消费者消费？

如果多个消费者在同⼀个消费组，那么只有⼀个消费者可以收到订阅的topic中的消息。换⾔之，同⼀个消费组中只能有⼀个消费者收到⼀个topic中的消息。
```python
./kafka-console-consumer.sh \
--bootstrap-server 172.16.253.38:9092 \
--consumer-property group.id=testGroup \
--topic test

```

**多播消息**

不同的消费组订阅同⼀个topic，那么不同的消费组中只有⼀个消费者能收到消息。实际上也是多个消费组中的多个消费者收到了同⼀个消息。

```python
./kafka-console-consumer.sh \
--bootstrap-server 172.16.253.38:9092 \
--consumer-property group.id=testGroup1 \
--topic test

./kafka-console-consumer.sh \
--bootstrap-server 172.16.253.38:9092 \
--consumer-property group.id=testGroup2 \
--topic test
```

**多播和单播消息的区别**

![](https://cloud.cxykk.com/images/2024/1/30/2257/1706626621544.png)

**查看消费组及信息**

```python
# 查看当前主题下有哪些消费组
./kafka-consumer-groups.sh \
--bootstrap-server 10.31.167.10:9092 \
--list

# 查看消费组中的具体信息：⽐如当前偏移量、最后⼀条消息的偏移量、堆积的消息数量
./kafka-consumer-groups.sh \
--bootstrap-server 172.16.253.38:9092 \
--describe \
--group testGroup
```

![](https://cloud.cxykk.com/images/2024/1/30/2257/1706626627917.png)

- Currennt-offset: 当前消费组的已消费偏移量
- Log-end-offset: 主题对应分区消息的结束偏移量(HW)
- Lag: 当前消费组未消费的消息数