消费者_消费者组实战

实战步骤：

1. 复制CustomTopicConsumer->CustomTopicConsumer2,将这两个类同时启动，即可启动在一个消费者组中的两个消费者。
2. 修改UnSyncCustomProducer：

循环次数从5改为10

每次发送数据休眠2毫秒

3. 分别运行CustomTopicConsumer和CustomTopicConsumer2
4. 然后运行UnSyncCustomProducer
5. 分别观察CustomTopicConsumer和CustomTopicConsumer2对应的控制台

可看到两个消费者在消费不同分区的数据

6. 重建一个新的只有一个分区的主题

xxxxxxxxxx
# 创建主题topicA 一个分区 2个副本
[root@node2 ~]# kafka-topics.sh --bootstrap-server node3:9092 --create --partitions 1 --replication-factor 2 --topic topicX

7. 修改UnSyncCustomProducer、CustomTopicConsumer和CustomTopicConsumer2三个类代码中的主题为topicX。
8. 先运行CustomTopicConsumer和CustomTopicConsumer2
9. 在运行UnSyncCustomProducer
10. 发现只有一个生产者能够获取到数据。
11. 修改CustomTo消费者_消费者组实战picConsumer的消费者组的id-testCg9,在执行步骤8和9，发现两个消费者都消费了10条数据。说明不同消费者组互不干扰。