kafka-consumer-api 相关问题

Kafka - 谁写入 __consumer_offsets 主题？

我对谁写了 __consumer_offset 主题有点困惑。 在 Kafka 权威指南 ch.4 p.75 中，这个细节非常通用 消费者如何提交抵消额？它会造成混乱......

Kafka Consumer 不断重新平衡

即使没有处理源记录，我的 Kafka Consumer 客户端也会在频繁的轮询之间保持重新平衡。 另外，我在正确的位置实现了consumer.pause()和consumer.resume()...

如何使用java获取kafka延迟

我目前开发了一个代码，可以显示主题、分区和日志偏移量。但我目前陷入如何获得分区滞后的问题上。我知道有一个kafka offset命令...

Apache kafka - 消费者延迟选项

我想在 Kafka 中为特定主题稍稍延迟启动一个消费者。详细来说，我希望消费者在从 tim 开始的特定时间延迟后开始消费来自主题的消息...

Kafka Consumer组中的所有Consumer消费所有Produced记录

当我们创建一个消费者组来消费来自生产者的一组记录时，消费者组中的消费者将并行消费生成的记录，我认为这是默认行为。 难道是……

我没有收到 Kafka 内容中的密钥 - Python/confluence

我正在尝试使用Python脚本从主题接收消息。 从 confluence_kafka 导入消费者，KafkaError 导入uuid # 卡夫卡经纪人详细信息 经纪人=“某事” 主题=“

对 kafka 消费者组进行一次重新平衡，同时动态添加新成员并删除现有成员

我有一个场景，我需要动态/编程地从某个组中删除现有的（低性能）kafka 消费者，并同时添加另一个（高性能）kafka 消费者...

如果kafka消费者作为主项目的依赖项而成为war的一部分，那么它会消费生产者生成的事件吗？

我正在运行一个项目，其中包含主题 A 的 Kafka 生产者。 对于同一个项目，我有一个依赖战争，其中包含该主题 A 的 Kafka 消费者。 第一个问题 该事件会生成...

Java Kafka Consumer - 消费者超时

我正在尝试构建一个 Kafka Consumer，预计它的存活时间约为 60 分钟。也就是说，轮询消息 60 分钟，然后退出轮询主题。有没有这样的房产

在Kafka中，如果我们有一个Consumer和三个分区，那么来自所有分区的Consumer消费者消息如何同时并行或逐一并行

在Kafka中，如果主题中有一个Consumer和三个分区，那么Consumer如何一次性或一一并行地从所有分区消费消息？ 我只是想知道什么是

Kafka Streams - 暂停和恢复

我有一个流应用程序，它消耗消息的速度通常很快，但有时需要很长时间（最多 30 分钟）。该行为是不确定的，我们在处理消息之前不知道......

如何在Kafka topic中触发compaction？

我使用以下设置创建主题： 最终 AdminClient localKafkaAdmin = AdminClient.create(consumerProps); 最终 NewTopic 主题 = new NewTopic("test-v1", 1, (short) 1); 地图<

我想将多个kafka主题数据放入单个kafka主题

假设我有 5 个 kafka 主题，每个主题都从不同的来源接收数据。 kafka-topic-1 的数据为： 这是kafka的第一个日志。它包含 mac 的详细信息。 kafka-topic-2 有 da...

Kafka消费者创建item到opensearch索引，RuntimeException：请求无法执行； I/O 反应器状态：已停止

当代码尝试在 Opensearch 的索引名称 wiki-index 中创建新文档时，我偶然发现了消费者端的运行时问题。注意：消费者能够阅读主题，出现问题......

Kafka 消费者报告创建

我有 4 个消费者 pod 读取和处理来自主题的数据，该主题通过每天读取文件发送大约 1000 条记录 所以我的工作是以这样一种方式配置消费者逻辑，即在

使用GCP Cloud Function无法从kafka读取数据

我想通过 GCP Cloud Function 从 kafka Topic 读取数据，为此我正在导入以下 packeges 在我的 main.py 文件中导入 从卡夫卡进口卡夫卡消费者 从 confluent_avro 导入

从kafka topic构建变更历史

我在 Kafka 中有一个主题，其中有我想在消费者中建立更改历史记录的记录。 为此，每当将消息附加到主题并为现有记录添加新值时...

简单的 Confluent Kafka .net 客户端无法连接到简单构建的 AK Kafka 代理

关于如何让一个简单的 .net Kafka 客户端连接到代理的任何提示？ 我构建了 Apache Kafka 并成功地遵循了快速入门（创建主题、生成事件、使用事件）。 使用

Alpakka Kafka Consumer.committablePartitionedSource 每个分区是否使用单独的 kafka 消费者

我想了解 Consumer.committablePartitionedSource 是否为每个分区使用单独的 kafka 消费者（我所有的分区都分配给一台机器）

Reactor Kafka 优雅关闭和暂停消费者

Spring Application使用Reactor Kafka消费消息。 问题 1：是否有标准约定在应用程序关闭期间暂停消息消费并完成处理动态消息？