kafka-consumer-api
-
Kafka消费者在循环消费消息时丢失消息
-
Kafka Headers 作为批处理模式的列表
-
从 Kafka 检索信息，该信息的字段与很长列表的一个值匹配
-
为 Kafka 消费者随机生成的组 ID
-
Kafka消费者超时或要下载的消息数
-
强制 Kafka 客户端停止从主题中读取消息
-
如何从应用程序外部停止 Kafka Listener bean？
-
Python-Kafka：无限轮询主题
-
如何为我的 kafka 消费者使用现有的 avro 模式？
-
Kafka Consumer Deserializer 是否必须匹配 Producer Serializer？
-
为什么要为 Kafka 使用我们自己的 Offset Repository
-
多主题流监听kafka之间通信出错|未从 .properties 文件中获取应用程序 ID
-
使用 python 消费者将 avro 序列化消息转换为 json
-
为什么在使用相同的 groupId 重新创建消费者组后偏移量不会重置为 0
-
kafka-consumer-groups 命令不显示 spark 结构化流应用程序（消费者）的 LAG 和 CURRENT-OFFSET
-
重置偏移量和寻找最新偏移量的无限循环
-
设计 Kafka 消费者和生产者以实现可扩展性
-
根据消费者请求将点播数据流式传输到 Kafka 主题
-
如何在 Kafka 生产者中从外部 API 读取数据并将其发送给 Scala 中的 Kafka 消费者
-
如何从特定日期接收来自kafka的数据