kafka-consumer-api
-
Kafka:使用 java 更改特定主题的分区数
-
如何在 Kafka Consumer API 中使用 key 读取数据?
-
kafka 中的多处理-python
-
无法在kafka消费者下设置'max.poll.records',其中cons.poll仍然returns分区下的所有记录
-
kafka 0.90 consumer persist group between runs
-
自动缩放 worker/daemon 作为 Kafka 消费者
-
Kafka(0.9.0.1)当所有消费者死亡时偏移量消失
-
在没有 Confluent 组件的情况下从 Kafka 生成和使用 Avro 消息
-
如何在 OSGI 框架中配置 Kafka 0.9.0.0 消费者?
-
为什么我的具有相同组 ID 的 Kafka 消费者不平衡?
-
Kafka 在组名级别重新平衡?
-
Kafka 自动提交间隔最佳实践
-
为什么卡夫卡消费者不听第一条消息?
-
Apache Kafka 0.9 Java API 从主题开始消费所有消息
-
Kafka 消费者组抵消保留
-
卡夫卡集群设置超时读取套接字错误
-
如何在kafka中定义多个序列化器?
-
来自 Kafka 源的 Spark Streaming 返回检查点或倒带
-
Kafka 生产者创建主题但无法发送消息
-
有什么方法可以保持单个消费者的 kafka 主题分区之间的消息顺序?