注意:

在没有配置的情况下,group.id是自动生成的,如果想要人为定义,如下

cd /home/kafka/software/kafka_2.10-0.9.0.1/config
cp consumer.properties consumer1.properties

修改group.id内容为自己指定的group.id,如下

vim consumer1.properties

在这里插入图片描述

启动消费者时指定group.id的配置文件

./bin/kafka-console-consumer.sh --zookeeper 172.16.100.134:2181 --topic connect-test --consumer.config config/consumer1.properties
Logo

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

更多推荐