事件起因

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

查询

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

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

 解决方案

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

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

 

Logo

华为开发者空间,是为全球开发者打造的专属开发空间,汇聚了华为优质开发资源及工具,致力于让每一位开发者拥有一台云主机,基于华为根生态开发、创新。

更多推荐