kafka-consumer-api
-
线程 "StreamThread-1" org.apache.kafka.streams.errors.StreamsException 中的异常:重新平衡失败
-
kafka-node 从最后一个偏移量开始消费
-
Kafka Consumer - 轮询行为
-
kafka客户端可以扮演消费者和生产者的多重角色吗
-
使用 Kafka 的日志压缩,如果消费者没有落后于某个定义的时间限制,我该怎么做才能保证消费者不会错过消息?
-
Kafka 的 Confluent Python API
-
kafka-node - 将参数传递给异步函数 consumer.on();
-
从副本消费
-
为什么 commitAsync 无法提交前 2 个偏移量
-
Kafka:监控分配给分区主题的消费者的滞后
-
kafka 0.8 与 kafka 0.10 的区别
-
在 Spark Streaming 中缓存 DStream
-
Kafka Consumer poll() 方法被阻塞
-
Kafka Java SimpleConsumer 奇怪的编码
-
读取字段 'topic_metadata' 时出错:读取大小为 1139567 的数组时出错,只有 45 个字节可用
-
是否可以在Kafka+Spark Streaming中获取特定的消息偏移量?
-
使用 KafkaConsumer 0.10.0 读取 0.9.0 消息?
-
Flink Kafka Consumer 在使用 DataStream 键时抛出空指针异常
-
读取字段 'topics' 时出错:Kafka 中的 java.nio.BufferUnderflowException
-
主题、分区和键