kafka-consumer-api
-
KafkaConsumer 0.10 Java API 错误消息:没有分区的当前分配 我正在使用KafkaConsumer 0.10 Java api。我想从特定分区和特定偏移量消耗。我查了一下,发现有一个寻求方法,但它抛出了一个异常。有人有类似的用例或解决方案吗? 法典:
-
Kafka 使用者如何从多个分配的分区中消费 tl;博士;我试图理解分配了多个分区的单个使用者如何处理访问分区的消耗记录。 例如: 在移动到下一个分区之前完全处理单个分区。 每次处理每个分区中的可用记录块。 处理来自第一个可
-
卡夫卡消费者。commitSync vs commitAsync 语录 缺点是,虽然 commitSync() 将重试提交,直到它成功或遇到不可重放的故障,但 commitAsync() 不会重试。 这句话我不清楚。我假设消费者向代理发送提交请求,如果代理在某个超时内
-
Kafka 使用者偏移量超出范围,未为分区配置重置策略 在启动 Kafka 使用者时获得以下异常。 org.apache.kafka.clients.consumer.OffsetOutOfRangeException: Offsets 超出范围,没有为分区配置重置策略{test-0=29898318} Kafka 版本: 9.0.0 Java 7
-
如何以健壮的方式处理kafka发布失败 我正在使用Kafka,我们有一个用例来构建一个容错系统,甚至不应该错过任何一条消息。所以问题是:如果发布到Kafka由于任何原因(ZooKeeper关闭,Kafka代理关闭等)而失败,我们如何可靠地处理
-
KafkaConsumer Java API subscribe() vs assign() 我是Kafka Java API的新手,我正在努力使用来自特定Kafka主题的记录。 我知道我可以使用方法从主题开始轮询记录。Kafka还提供了方法,如果我想从主题的选定分区开始轮询记录。 我想知道这是否
-
Kafka 使用者异常和偏移量提交 我一直在尝试为Spring Kafka做一些POC工作。具体来说,我想尝试在Kafka中使用消息时处理错误的最佳实践。 我想知道是否有人能够帮助: 分享有关 Kafka 消费者在发生故障时应执行的操作的最佳
-
简单的卡夫卡消费者示例不起作用 我有一个简单的类来使用来自kafka服务器的消息。大多数代码是从 org.apache.kafka.clients.consumer.KafkaConsumer 的评论中复制的.java。 我应该如何配置 key.deserializer?
-
即使在 Kafka 中进行轮询后,也不会发生分区的当前分配 我有Java 8应用程序使用Apache Kafka 2.11-0.10.1.0。我需要使用该功能来存储来自分区的旧消息。但是,我每次尝试时都会遇到异常。这是我的类,负责将主题发送到指定的时间戳:
-
何时使用 ConcurrentKafkaListenerContainerFactory? 我是kafka的新手,我浏览了,但我什么也听不懂。有人可以解释一下何时使用这个类吗?我已经使用了该类,但我看到在我当前的项目中被使用。请解释它的作用。
标签