天津网站优化首页,企业二级域名自助建站平台,房地产网站建设的目的,网站字体颜色大小以往使用 kafka-console-consumer.sh 消费 Kafka 消息时并没有太在意过 Consumer Group#xff0c;在命令行中也不会使用 --group 参数#xff0c;本文针对 Kafka Console Client 命令行中的 Consumer Group 进行一次统一说明。
1. 如不设置 --group 参数会自动生成一个 Con…以往使用 kafka-console-consumer.sh 消费 Kafka 消息时并没有太在意过 Consumer Group在命令行中也不会使用 --group 参数本文针对 Kafka Console Client 命令行中的 Consumer Group 进行一次统一说明。
1. 如不设置 --group 参数会自动生成一个 Consumer Group ID
通常我们在使用 kafka-console-consumer.sh 的时候是不会设置 --group 参数的从使用体验上也看不出有什么差异原因在于 Kafka Console Client 会自动为当前这次请求自动创建一个 GroupID一般会命名为 console-consumer-xxxx每执行一次 kafka-console-consumer.sh 就生成一个新的 GroupID以下是测试过程 从上面的测试可以看出每执行一次 kafka-console-consumer.sh 都会自动创建一个新的 Consumer Group命令行启动的 Consumer 就在这个 Group 中且也只有这一个 Consumer。
2. 设置 --group 参数多个 kafka-console-consumer.sh 加入同一 Consumer Group
我们的测试用 topic 有3个 Partition, 我们打开三个 Console分别执行一遍
kafka-console-consumer.sh --bootstrap-server $KAFKA_BOOTSTRAP_SERVERS --topic osci.mysql-server-3.inventory.orders --group app-1然后向 Kafka 中插入三条数据avro 格式二进制数据得到如下输出
可以看到三个 kafka-console-consumer.sh 在同一个 Group 下工作各自对接一个 Partition所以写入的三条消息是在三个 Console 中输出出来的。这就是 Consumer Group 的标准行为。
