事件起因

今天跑了一下kafka的示例demo,突然意识到一个问题。消费者拉取broker的消息时需要指定group id,而生产者将消息发送到broker的时候并不会指定group id,那么消费者的group id从哪里获取呢?

查询

查阅我的这篇文章 kafka消费者 的3.1小节,

如果不配置该参数,则会抛出异常。为此,笔者验证了一下:

 解决方案

去Kafka目录下的config目录,找到consumer.properties

打开该配置文件,赫然发现group id这个配置项。

 

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐