activeqmq 都是broker push 到 消费者，消费者 建立 messageListener
监听器 就可以 获取消息，但kafka 是 需要去broker pull消息， 怎么才能知道 broker中 已经 有了对应 ｔｏｐｉｃ 呢 ？定时 获取？
kafka 消费者 获取消息
- 写回答
- 好问题 0 提建议
- 关注问题
分享- 邀请回答
-
2条回答 默认 最新
陶超强 2016-03-27 07:28关注broker中的topic信息以及consumer进行pull过程中产生的offset都在zookeeper中有存储，consumer可以连接zookeeper查看对应topic的状态
解决 无用评论 打赏举报 分享
- 2022-06-03 23:02柳小葱的博客 上一期我们学习了kafka的broker部分主要介绍了kafka中的副本、kafka文件的存储的原理，以及kafka的高效读写的保证，今天我们来介绍kafka中的消费者原理，对往期内容感兴趣的小伙伴可以参考：消费者作为kafka中最重要...
- 2018-07-13 22:23在这个"Kafka大数据 生产者消费者实例"中，我们将探讨如何通过Java编程语言来实现Kafka的生产者和消费者。 首先，我们要理解Kafka中的**生产者（Producer）**，它是负责发布消息到特定主题的组件。在Java中，我们...
- 2025-04-30 18:40AI大数据智能洞察的博客 本文聚焦 Kafka 生态中生产者（Producer）与消费者（Consumer）的核心机制，深入解析消息生产的可靠性保障、消费端的高效处理策略，以及端到端一致性实现等关键议题。通过理论分析、数学建模与代码实战，为数据...
- 2022-08-04 11:44Kafka使用消费者拉取模式，消费者控制消息获取速度。 4. **Kafka基础架构** - **Producer**：负责生产消息，发送至Kafka broker。 - **Consumer**：负责消费消息，从broker读取。 - **Consumer Group**：由多个...
- 2018-09-26 11:253. **消息消费**：消费者订阅主题后，可以从Broker中获取消息进行消费。 4. **消息确认**：消费者消费完消息后会向Broker发送确认消息，表示消息已被成功处理。 #### 五、Kafka的应用场景 1. **日志收集**：Kafka...
- 2020-12-03 12:51肆意的湛蓝的博客 它可以处理消费者规模的网站中的所有动作流数据。这种动作(网页浏览，搜索和其他用户的行动)是在现代网络上的许多社会功能的一个关键因素。这些数据通常是由于吞吐量的要求而通过处理日志和日志聚合来解决。对于像...
- 2025-09-20 19:46Agentic AI人工智能与大数据的博客 Kafka生产者与消费者的最佳实践，本质是平衡可靠性与性能的艺术。对于生产者，关键是保证消息不丢失acks=all、幂等性）、优化吞吐量（批量发送、压缩）；对于消费者，关键是提高并发度（增加分区数、消费者实例）、...
- 2025-03-17 15:03一碗黄焖鸡三碗米饭的博客 Kafka 消费者位移（Offset）管理是 Kafka 系统中至关重要的一部分，合理的位移管理不仅能够提高数据的消费效率，还能够保证数据的一致性和可靠性。本文详细探讨了消费者位移的存储、自动提交与手动提交的方式，分析...
- 2025-04-26 23:13程序员光剑的博客 延迟消息处理是指消息在发送后不立即被消费，而是在指定的延迟时间后才被投递给消费者。这种能力在许多业务场景中都非常关键。Kafka原生机制对延迟消息的支持情况主流延迟消息实现方案的原理和比较各种方案的性能...
- 2025-03-10 21:27zxhl0927的博客 CheckPointCheckPoint:将Kafka Broker端重要的日志元数据保存下来。recovery-point-offset-checkpoint：表示已经刷写到磁盘的offset信息，对应LEO信息。replication-offset-checkpoint：用来存储每个replica的HW，...
- 没有解决我的问题, 去提问
