极客架构 2014-12-29 01:04 采纳率: 0%
浏览 8010

kafka 消费者 获取消息

activeqmq 都是broker push 到 消费者，消费者 建立 messageListener
监听器 就可以 获取消息，但kafka 是 需要去broker pull消息， 怎么才能知道 broker中 已经 有了对应　ｔｏｐｉｃ　呢　？定时　获取？

  • 写回答

2条回答 默认 最新

  • 陶超强 2016-03-27 07:28
    关注

    broker中的topic信息以及consumer进行pull过程中产生的offset都在zookeeper中有存储，consumer可以连接zookeeper查看对应topic的状态

    评论

报告相同问题？

  • kafka消费者创建不了 java kafka linux
    2022-08-23 10:01
    回答 1 已采纳 同一个消费组能同时消费的消费者数量和topic的分区数有关，估计是你的topic只有两个分区所以使用相同的groupid只有两个消费者在消费，加一个分区就好
  • Kafka消费者消费信息经常接收不到 java
    2022-12-21 00:45
    回答 1 已采纳 这篇博客也许可以解决你的问题👉 ：kafka消费者从kafka读取信息
  • 一台机器可以即可以充当kafka消费者又充当kafka生产者吗？ java kafka
    2022-01-10 15:46
    回答 3 已采纳 消费者和生产者与机器无关，这是不同的概念，消费者与生产者只是在Kafka中的角色，不同角色干不同的事情
  • 大数据之kafka消费者
    2022-06-03 23:02
    柳小葱的博客 上一期我们学习了kafka的broker部分主要介绍了kafka中的副本、kafka文件的存储的原理，以及kafka的高效读写的保证，今天我们来介绍kafka中的消费者原理，对往期内容感兴趣的小伙伴可以参考：消费者作为kafka中最重要...
  • Springboot集成kafka，应用很卡，消费很慢 java kafka spring boot
    2022-10-25 09:26
    回答 5 已采纳 感觉消息堆积有点厉害，查一下代码，是因为什么原因导致消息一直没被消费。如果只是前端数据，可以丢弃的话，把队列清空，看看还会不会卡？
  • kafka消费者迭代器卡死
    2016-10-25 09:13
    回答 4 已采纳 明白了，offset已经指到最后了，然后获取不到数据就一直等待状态，我以为卡死，生产者发送几个数据进去就行了
  • 【kafka】kafka消息生产者抛异常
    2018-04-27 17:31
    回答 2 已采纳 1, 先确认你的网络有没有问题 2，在向服务器发起连接后，在kafka的服务器配置中有zookeeper.connect=xx.xx.xx.xx：2181的配置 这时候kafka会查找zookeep
  • kafka大数据 生产者消费者实例
    2018-07-13 22:23
    在这个"Kafka大数据 生产者消费者实例"中，我们将探讨如何通过Java编程语言来实现Kafka的生产者和消费者。 首先，我们要理解Kafka中的**生产者（Producer）**，它是负责发布消息到特定主题的组件。在Java中，我们...
  • flink消费kafka数据延迟 flink postgresql scala 有问必答
    2022-01-28 09:47
    回答 1 已采纳 那最后写入到库了吗，如果写不进去，上游kafka肯定会延迟越来越大的，可以在sink里多打印下错误，或者设置写入超时时间，问题应该在写入
  • 如何在Golang中创建kafka消费者组？
    2017-02-01 18:07
    回答 2 已采纳 The consumer group is specified by the second argument of the cluster consumer "constructor". Here
  • kafka中的消费拦截器 flink java kafka
    2021-07-05 16:53
    回答 1 已采纳 value的值为[B@1e1e585b这个明显是序列化后的Bytes字节类型嘛你反序列化成string就ok了
  • 尚硅谷大数据技术之Kafka1
    2022-08-04 11:44
    Kafka使用消费者拉取模式，消费者控制消息获取速度。 4. **Kafka基础架构** - **Producer**：负责生产消息，发送至Kafka broker。 - **Consumer**：负责消费消息，从broker读取。 - **Consumer Group**：由多个...
  • kafka如何获取到发送失败的数据 java kafka 有问必答
    2021-07-27 10:36
    回答 1 已采纳 kafka调用send方法发送数据后 会返回一个ListenableFuture 这个ListenableFuture可以添加callback进行监听d
  • kafka消费者接收不到消息_kafka(一)
    2020-12-03 12:51
    肆意的湛蓝的博客 它可以处理消费者规模的网站中的所有动作流数据。这种动作(网页浏览，搜索和其他用户的行动)是在现代网络上的许多社会功能的一个关键因素。这些数据通常是由于吞吐量的要求而通过处理日志和日志聚合来解决。对于像...
  • 大数据之Kafka
    2018-09-26 11:25
    3. **消息消费**：消费者订阅主题后，可以从Broker中获取消息进行消费。 4. **消息确认**：消费者消费完消息后会向Broker发送确认消息，表示消息已被成功处理。 #### 五、Kafka的应用场景 1. **日志收集**：Kafka...
  • 没有解决我的问题, 去提问

悬赏问题

  • ¥15 宇视监控服务器无法登录
  • ¥15 PADS Logic 原理图
  • ¥15 PADS Logic 图标
  • ¥15 电脑和power bi环境都是英文如何将日期层次结构转换成英文
  • ¥20 气象站点数据求取中~
  • ¥15 如何获取APP内弹出的网址链接
  • ¥15 wifi 图标不见了 不知道怎么办 上不了网 变成小地球了
  • ¥50 STM32单片机传感器读取错误
  • ¥50 power BI 从Mysql服务器导入数据，但连接进去后显示表无数据
  • ¥15 (关键词-阻抗匹配，HFSS，RFID标签天线)