kafka-consumer-api
-
在 producer/consumer 个客户端中绕过 Zookeeper?
-
将包含键值对的数据流转换为 DataStream[ObjectNode] json 到映射 Scala
-
Apache Kafka 是否提供异步订阅回调 API?
-
Kafka scala Consumer代码——打印消费记录
-
Kafka Consumer 卡在加入集群
-
Consumer.poll() returns 新记录,即使没有提交偏移量?
-
Kafka 的 retention.ms 没有被 Kafka 0.10.2 强制执行?
-
Kafka Streaming 不适用于多个实例
-
如何配置 Kafka 主题,以便 RDMS 和图形等数据库可以以事件的形式使用互连的实体模式
-
Kafka倒序消费消息
-
Kafka 0.8 的高级消费者 api 生命周期
-
一些提交偏移量调用在 kafka 中失败
-
两个 Kafka 消费者导致彼此发生奇怪的行为
-
Kafka:分布式进程和存储
-
防止kafka consumer长时间进程超时
-
Kafka 消费者异常和抵消提交
-
如果不从头开始阅读,Kafka 就无法消费 -Java
-
按键加入多个Kafka主题
-
Spring kafka消费者,在运行时寻找偏移量?
-
Spring 启动 Kafka:由于 NoSuchBeanDefinitionException,无法启动消费者