配置了SASL之后 ,命令端的from -begining 消费一次之后就不能在次消费了

马踏紫陌 发表于: 2018-11-02   最后更新时间: 2018-11-02 14:21:39   2,272 游览
发表于 2018-11-02
添加评论

老哥,你的描述那么少,我咋帮你看呢。

我在想是不是因为-consumer.config影响了from-begining

大神,问题描述现在应该很清楚吧

半兽人 -> 马踏紫陌 5年前

你完整的消费者命令贴一下。

马踏紫陌 -> 半兽人 5年前
bin/reader-kafka-console-consumer.sh --bootstrap-server zk1:9092,zk2:9092,zk3:9092 --topic test02 --from-beginning --consumer.config config/consumer.config 

半兽人 -> 马踏紫陌 5年前

你加了SASL后,你的命令要带证书的。

马踏紫陌 -> 半兽人 5年前

security.protocol=SASL_PLAINTEXT


sasl.mechanism=PLAIN


group.id=test-group
马踏紫陌 -> 半兽人 5年前

这是那个证书

马踏紫陌 -> 半兽人 5年前

而且新的启动consumer脚本里已经把kafka_client_jaas.conf加进去了

马踏紫陌 -> 半兽人 5年前

大神,我发现删除里面的group-id配置就好了

马踏紫陌 -> 半兽人 5年前

请问这个groupid有什么实质性的作用吗

半兽人 -> 马踏紫陌 5年前

group.id消费者的组名,标识消息消费到哪里了,但是你带了--from-beginning,所以一直都可以从头消费。所以你好了,我很好奇怎么好的。。

马踏紫陌 -> 半兽人 5年前

不过在另一套集群上,我只给了topic的权限,没给group的权限,用带有groupid=test-group的新的Consumer消费命令消费,他也没提示没有这个group的权限,我就很奇怪了

半兽人 -> 马踏紫陌 5年前

在检查检查吧,关注下默认权限。

马踏紫陌 -> 半兽人 5年前

另一套集群,如果新的consumer消费的话,不带group-id,会提示Not au。。。 to access console-consuer-6998,带上group-id=test-group消费的时候,from-begining不起作用

马踏紫陌 -> 半兽人 5年前

大神。最新的问题有什么解决意见吗

你的答案

查看kafka相关的其他问题或提一个您自己的问题