kafka-consumer-api
-
什么决定了 Kafka 消费者的偏移量?
-
kafka-node 消费者收到 offsetOutOfRange 错误
-
如何将 Spark 消耗的最新偏移量保存到 ZK 或 Kafka 并在重启后可以读回
-
如何停止程序中的Python Kafka Consumer?
-
Kafka - 使用高级消费者实现延迟队列
-
如何通过 SimpleConsumer 在 Kafka 中获取没有获取请求的消息的大小(元数据)?
-
Scala:class 在将 class 传递给另一个 class 时采用类型参数?
-
什么是 Kafka ConsumerConnector 的主题计数参数
-
"Rebalancing" 在 Apache Kafka 上下文中意味着什么?
-
如何在 Eclipse 下使用自定义 Kafka 生产者修复 NoClassDefFoundError?
-
kafka:'soTimeout'、'bufferSize' 和 'minBytes' 对 SimpleConsumer 意味着什么?
-
分区的 Kafka 多个消费者
-
Kafka 消费者获取主题的元数据失败
-
kafka spout 不发射数据
-
Kafka Java API 偏移操作说明
-
Kafka消费者-如何添加主题
-
高级消费者块上的 commitOffsets 是否?
-
高级消费者是否利用了 Kafka 0.8.2 中新的偏移量管理?
-
当消费来自kafka的消息时,通常使用一个组id.But,SimpleConsumer只使用一个clientName.The clientName是组id?
-
我想知道,当startOffsetTime的值为kafka.api.OffsetRequest.EarliestTime()时,偏移值是多少?