老哥,你的描述那么少,我咋帮你看呢。
https://blog.csdn.net/linux12a/article/details/77375274就是根据这个博客做的,然后新的消费者命令消费,并且带上了from-begining参数,发现并没有消费历史数据和不带参数的效果是一样的
我在想是不是因为-consumer.config影响了from-begining
大神,问题描述现在应该很清楚吧
你完整的消费者命令贴一下。
你加了SASL后,你的命令要带证书的。
这是那个证书
而且新的启动consumer脚本里已经把kafka_client_jaas.conf加进去了
大神,我发现删除里面的group-id配置就好了
请问这个groupid有什么实质性的作用吗
group.id消费者的组名,标识消息消费到哪里了,但是你带了--from-beginning,所以一直都可以从头消费。所以你好了,我很好奇怎么好的。。
不过在另一套集群上,我只给了topic的权限,没给group的权限,用带有groupid=test-group的新的Consumer消费命令消费,他也没提示没有这个group的权限,我就很奇怪了
在检查检查吧,关注下默认权限。
另一套集群,如果新的consumer消费的话,不带group-id,会提示Not au。。。 to access console-consuer-6998,带上group-id=test-group消费的时候,from-begining不起作用
大神。最新的问题有什么解决意见吗
找不到想要的答案?提一个您自己的问题。
0 声望
这家伙太懒,什么都没留下
老哥,你的描述那么少,我咋帮你看呢。
https://blog.csdn.net/linux12a/article/details/77375274就是根据这个博客做的,然后新的消费者命令消费,并且带上了from-begining参数,发现并没有消费历史数据和不带参数的效果是一样的
我在想是不是因为-consumer.config影响了from-begining
大神,问题描述现在应该很清楚吧
你完整的消费者命令贴一下。
你加了SASL后,你的命令要带证书的。
security.protocol=SASL_PLAINTEXT
sasl.mechanism=PLAIN
group.id=test-group
这是那个证书
而且新的启动consumer脚本里已经把kafka_client_jaas.conf加进去了
大神,我发现删除里面的group-id配置就好了
请问这个groupid有什么实质性的作用吗
group.id消费者的组名,标识消息消费到哪里了,但是你带了--from-beginning,所以一直都可以从头消费。所以你好了,我很好奇怎么好的。。
不过在另一套集群上,我只给了topic的权限,没给group的权限,用带有groupid=test-group的新的Consumer消费命令消费,他也没提示没有这个group的权限,我就很奇怪了
在检查检查吧,关注下默认权限。
另一套集群,如果新的consumer消费的话,不带group-id,会提示Not au。。。 to access console-consuer-6998,带上group-id=test-group消费的时候,from-begining不起作用
大神。最新的问题有什么解决意见吗
你的答案