kafka-consumer-api
-
JBOSS 给出 org.apache.kafka.common.KafkaException: auth.conf 无法读取
-
在同一台机器上的两个 docker conatiners 中创建 kafka broker 和 zookeeper 的优缺点是什么
-
如何从 kafka 中收到的消息中获取 Avro 模式对象?
-
发布和使用不同类型消息的最佳方式是什么?
-
kafka-python - 如何提交分区?
-
如何使用直接流在 Kafka Spark Streaming 中指定消费者组
-
Kafka主题分区和Spark执行器映射
-
卡夫卡抛出 java.nio.channels.ClosedChannelException
-
如何在 apache kafka 中创建主题?
-
WARN 获取相关 ID 为 1 的元数据时出错:{MY_TOPIC?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient)
-
SBT 无法导入 Kafka encoder/decoder 类
-
AssertionError: Unassigned partition
-
只从 Kafka 读取密钥
-
org.apache.kafka.common.errors.ApiException: 会话超时不在可接受的范围内
-
如何克服kafka.consumer.ConsumerTimeoutException?
-
无法使用基于 java 的 Kafka 消费者读取一条消息
-
具有解码器问题的 Kafka Avro 消费者
-
kafka __consumer_offsets 主题的分区数过多
-
为什么 Kafka Consumer 不断收到相同的消息(offset)
-
Kafka Consumer 如何(应该)应对有毒消息