我的生产者和消费者在同一个服务， 但是有时候重启服务消费者不消费 有时候消费 当他不消费的时候，我重新更换个groupid 下次重启必然能正常消费 但是再重启就又不行了 需要重新更换 不知道为啥
1条回答 默认 最新
- 2022-12-21 00:45回答 1 已采纳 这篇博客也许可以解决你的问题👉 ：kafka消费者从kafka读取信息
- 2022-08-23 10:01回答 1 已采纳 同一个消费组能同时消费的消费者数量和topic的分区数有关，估计是你的topic只有两个分区所以使用相同的groupid只有两个消费者在消费，加一个分区就好
- 2022-02-16 19:32回答 4 已采纳 重新开一个topic，然后先启动consumer，再启动producer，再发消息，你这个可能是consumer已经在broker里有了自己的offset，就会读不到之前producer发送到brok
- 2022-10-23 14:52loveLifeLoveCoding的博客 今天出现了这样一个问题, A说他的kafka消息发送了;B说它没有接收到;好,带着上面的问题,我们来一步步排查一下问题所在。
- 2017-02-01 18:07回答 2 已采纳 The consumer group is specified by the second argument of the cluster consumer "constructor". Here
- 2022-01-10 15:46回答 3 已采纳 消费者和生产者与机器无关，这是不同的概念，消费者与生产者只是在Kafka中的角色，不同角色干不同的事情
- 2022-10-25 09:26回答 5 已采纳 感觉消息堆积有点厉害，查一下代码，是因为什么原因导致消息一直没被消费。如果只是前端数据，可以丢弃的话，把队列清空，看看还会不会卡？
- 2020-12-20 16:36weixin_39540934的博客 与生产者对应的是消费者，应用程序可以通过 KafkaConsumer 来订阅主题，并从订阅的主题拉取消息。不过在使用 KafkaConsumer 之前需要了解消费者与消费组的概念，否则无法理解如何使用 KafkaConsumer。一、消费者与...
- 2022-01-28 09:47回答 1 已采纳 那最后写入到库了吗，如果写不进去，上游kafka肯定会延迟越来越大的，可以在sink里多打印下错误，或者设置写入超时时间，问题应该在写入
- 2016-10-25 09:13回答 4 已采纳 明白了，offset已经指到最后了，然后获取不到数据就一直等待状态，我以为卡死，生产者发送几个数据进去就行了
- 2021-07-02 11:07回答 2 已采纳 对kafka来说，只要这条数据发出去了，就算消费了，你消费者怎么处理，和kafka无关了。对消费者来说， 你只需要消费下一条就行了。至于偏移量， 你第一次消费的时候，是要发送偏移的，这个你消费者要本地
- 2022-07-24 15:07流年ln的博客 与其它消息中间件不同的是：Kafka消费理念中还有一层消费者组（Consumer Group）的概念，一个消费者组包含多个消费者，消息发布到主题后，会投递给每个消费者组中的其中一个消费者。 如上图，一个主题有四个分区，P0...
- 2016-05-09 11:56回答 1 已采纳 你的这个结构首先要换一下。 如果你要去读取group中不同分区中的数据。对于你的consumer端来说，应该是1对1进行读取，也就是说，一个java进程对应一个分区partition。 你自己
- 2020-12-29 06:19房小探的博客 我是卡夫卡的新手.我在我的本地机器上创建了一个java生成器,并在另一台机器上设置了一个...但是,当我检查机器M2上的控制台消费者时,我看不到这些消息.我的java生产者代码是：import org.apache.kafka.clients.pr...
- 2021-01-13 23:23HackerLZH的博客 在每个结点的server.properties里面增加advertised.host.name=主机ip，然后重启kafka就行了。 在官方文档其实有提到，不是被弃用了，而是不可或缺！ 这里也说了是当advertised.listeners和listeners没有设置时，就...
- 没有解决我的问题, 去提问
问题事件
系统已结题
3月8日
已采纳回答
2月28日-
创建了问题
12月21日
悬赏问题
- ¥15 对于这个问题的解释说明
- ¥200 询问：python实现大地主题正反算的程序设计，有偿
- ¥15 smptlib使用465端口发送邮件失败
- ¥200 总是报错，能帮助用python实现程序实现高斯正反算吗？有偿
- ¥15 对于squad数据集的基于bert模型的微调
- ¥15 为什么我运行这个网络会出现以下报错？CRNN神经网络
- ¥20 steam下载游戏占用内存
- ¥15 CST保存项目时失败
- ¥15 树莓派5怎么用camera module 3啊
- ¥20 java在应用程序里获取不到扬声器设备