kafka-consumer-api
-
是什么决定了卡夫卡消费者的偏移量? 我对卡夫卡比较陌生。我已经做了一些实验,但是关于消费者抵消,我不清楚一些事情。根据我到目前为止的理解,当消费者开始时,它将开始读取的偏移量由配置设置决定(如果我错了,请纠
-
如何获取 kafka 主题分区的最后/结束偏移量? 我正在使用Java编写一个消费者。我想保持消息的实时性,因此,如果有太多消息等待消耗,例如1000或更多,我应该放弃未消耗的消息,并从最后一个偏移量开始消耗。 对于这个问题,我尝试比
-
-
Kafka 如何存储每个主题的偏移量? 在轮询Kafka时,我使用该函数订阅了多个主题。现在,我想设置要从每个主题中阅读的偏移量,而不是在每个主题之后重新订阅。在轮询数据之前,对每个主题名称进行迭代调用是否能获得结果
-
了解使用者组 ID 我重新安装了Apache Kafka 0.10.1.0。 我能够在命令提示符下发送/接收消息。 在使用生产者/消费者Java示例时,我无法知道消费者示例 group.id 参数。 让我知道如何解决此问题。 以下是我使用的消
-
Kafka - 使用高级使用者的延迟队列实现 想要使用高级使用者 API 实现延迟的使用者 主要思想: 按键生成消息(每个消息都包含创建时间戳),这可确保每个分区都按生成时间对消息进行排序。 auto.commit.enable=false (将在每个消息进
-
kafka消费者自动提交如何工作? 我正在读: 自动提交:可以将 auto.commit 设置为 true,并使用以毫秒为单位的值设置 auto.commit.interval.ms 属性。启用此功能后,Kafka 使用者将提交为响应其 poll() 调用而收到的最后一条消息的
标签