kafka-consumer-api
-
使用命令行在kafka中消费消息时如何设置组名？
-
为什么在创建 KafkaConsumer 时出现 ConfigException 'Expected a comma separated list' 错误
-
Kafka - 如何监视新消息
-
kafka 将消息放回队列，可以吗？
-
如何获取kafka主题分区的last/end偏移量？
-
删除不用的kafka消费者组
-
kafka.common.KafkaStorageException: I/O 附加到日志的异常
-
Storm 在 java 中从 Kafka 读取数据
-
Kafka SimpleConsumer（低级消费者）使用 cases/advantages
-
Kafka Rest Proxy 消费者创建
-
如果 group cordinator 长时间不调用 poll() 是否会认为 kafka 消费者 (0.9) 已死？
-
需要澄清有关 Kafka 自动提交和 auto.commit.interval.ms
-
Kafka 0.8.2 自定义 API 库？
-
来自 Kafka Consumer 的 Spark Streaming
-
卡夫卡消费者不消费
-
kafka 消费者（通过新消费者 api 创建）的偏移量和滞后设置为未知
-
附加分配给特定分区的 KafaConsumer
-
在 Spark 批处理作业中读取 Kafka 主题
-
了解 Kafka 主题和分区
-
如何使用 kafka 生产者向同一主题发送消息？