码农终将翻身 2022-12-21 00:45 采纳率: 59.1%
浏览 9
已结题

Kafka消费者消费信息经常接收不到

我的生产者和消费者在同一个服务， 但是有时候重启服务消费者不消费 有时候消费 当他不消费的时候，我重新更换个groupid 下次重启必然能正常消费 但是再重启就又不行了 需要重新更换 不知道为啥

  • 写回答

1条回答 默认 最新

  • CSDN-Ada助手 CSDN-AI 官方账号 2022-12-21 02:08
    关注
    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

    报告相同问题？

    • Kafka消费者消费信息经常接收不到 java
      2022-12-21 00:45
      回答 1 已采纳 这篇博客也许可以解决你的问题👉 ：kafka消费者从kafka读取信息
    • kafka消费者创建不了 java kafka linux
      2022-08-23 10:01
      回答 1 已采纳 同一个消费组能同时消费的消费者数量和topic的分区数有关，估计是你的topic只有两个分区所以使用相同的groupid只有两个消费者在消费，加一个分区就好
    • kafka拉取不到数据 java kafka 分布式 有问必答
      2022-02-16 19:32
      回答 4 已采纳 重新开一个topic，然后先启动consumer，再启动producer，再发消息，你这个可能是consumer已经在broker里有了自己的offset，就会读不到之前producer发送到brok
    • kafka 主动消费_Kafka 服务中消费者创建详解
      2020-12-20 16:36
      weixin_39540934的博客 与生产者对应的是消费者，应用程序可以通过 KafkaConsumer 来订阅主题，并从订阅的主题拉取消息。不过在使用 KafkaConsumer 之前需要了解消费者与消费组的概念，否则无法理解如何使用 KafkaConsumer。一、消费者与...
    • 如何在Golang中创建kafka消费者组？
      2017-02-01 18:07
      回答 2 已采纳 The consumer group is specified by the second argument of the cluster consumer "constructor". Here
    • 一台机器可以即可以充当kafka消费者又充当kafka生产者吗？ java kafka
      2022-01-10 15:46
      回答 3 已采纳 消费者和生产者与机器无关，这是不同的概念，消费者与生产者只是在Kafka中的角色，不同角色干不同的事情
    • Springboot集成kafka，应用很卡，消费很慢 java kafka spring boot
      2022-10-25 09:26
      回答 5 已采纳 感觉消息堆积有点厉害，查一下代码，是因为什么原因导致消息一直没被消费。如果只是前端数据，可以丢弃的话，把队列清空，看看还会不会卡？
    • 三、Kafka消费者
      2022-07-24 15:07
      流年ln的博客 与其它消息中间件不同的是：Kafka消费理念中还有一层消费者组（Consumer Group）的概念，一个消费者组包含多个消费者，消息发布到主题后，会投递给每个消费者组中的其中一个消费者。 如上图，一个主题有四个分区，P0...
    • flink消费kafka数据延迟 flink postgresql scala 有问必答
      2022-01-28 09:47
      回答 1 已采纳 那最后写入到库了吗，如果写不进去，上游kafka肯定会延迟越来越大的，可以在sink里多打印下错误，或者设置写入超时时间，问题应该在写入
    • kafka消费者迭代器卡死
      2016-10-25 09:13
      回答 4 已采纳 明白了，offset已经指到最后了，然后获取不到数据就一直等待状态，我以为卡死，生产者发送几个数据进去就行了
    • flink消费kafka flink java kafka 有问必答
      2021-07-02 11:07
      回答 2 已采纳 对kafka来说，只要这条数据发出去了，就算消费了，你消费者怎么处理，和kafka无关了。对消费者来说， 你只需要消费下一条就行了。至于偏移量， 你第一次消费的时候，是要发送偏移的，这个你消费者要本地
    • SpringBoot使用kafka事务-消费者方
      2023-09-03 14:25
      九万里编程的博客 spring:kafka:consumer:group-id: test_group #默认组id 后面会配置多个消费者组enable-auto-commit: false #关闭自动提交max-poll-records: 20 #批量消费 一次接收的最大数量注意bootstrap-servers-2这个key。
    • 有关kafka消费者的问题，描述如下
      2016-05-09 11:56
      回答 1 已采纳 你的这个结构首先要换一下。 如果你要去读取group中不同分区中的数据。对于你的consumer端来说，应该是1对1进行读取，也就是说，一个java进程对应一个分区partition。 你自己
    • Spring Boot+Kafka实战生产级Kafka消费组
      2023-08-06 01:35
      禅与计算机程序设计艺术的博客 Kafka是一个开源分布式消息系统，最初由LinkedIn开发，之后成为Apache项目的一部分。Kafka主要用于大数据实时流处理，具有低延迟、高吞吐量等特点。本文将会从基本概念、术语说明、原理及应用场景三个方面对Kafka...
    • Kafka 消费者
      2023-02-14 15:56
      ziyi813的博客 与生产者对应的是消费者，应用程序可以通过 KafkaConsumer 来订阅主题，并从订阅主题中拉取消息。
    • 没有解决我的问题, 去提问

    问题事件

    • 系统已结题 3月8日
    • 已采纳回答 2月28日
    • 创建了问题 12月21日

    悬赏问题

    • ¥15 Qt 不小心删除了自带的类，该怎么办
    • ¥15 我需要在PC端 开两个抖店工作台客户端.(语言-java)
    • ¥15 有没有哪位厉害的人可以用C#可视化呀
    • ¥15 可以帮我看看代码哪里错了吗
    • ¥15 设计一个成绩管理系统
    • ¥15 PCL注册的选点等函数如何取消注册
    • ¥15 问一下各位，为什么我用蓝牙直接发送模拟输入的数据，接收端显示乱码呢，米思齐软件上usb串口显示正常的字符串呢？
    • ¥15 Python爬虫程序
    • ¥15 crypto 这种的应该怎么找flag？
    • ¥15 代码已写好，求帮我指出错误，有偿！