事件起因
今天跑了一下kafka的示例demo,突然意识到一个问题。消费者拉取broker的消息时需要指定group id,而生产者将消息发送到broker的时候并不会指定group id,那么消费者的group id从哪里获取呢?
查询
查阅我的这篇文章 kafka消费者 的3.1小节,
如果不配置该参数,则会抛出异常。为此,笔者验证了一下:
解决方案
去Kafka目录下的config目录,找到consumer.properties
打开该配置文件,赫然发现group id这个配置项。
版权归原作者 邓不利东 所有, 如有侵权,请联系我们删除。