kafka-consumer-api
-
KafkaConsumer：`seekToEnd()` 不会让消费者从最新的偏移量开始消费
-
KStream/KsqlDb 在 Kubernetes 中使用持久状态存储的应用程序
-
如何在 Kafka 中使用属性文件映射类型
-
如何存储和处理 Offset Commit 请求以提交？
-
kafka消费者滞后增加太多
-
如果 Kafka 的消费者处理一条消息的时间过长怎么办？ Kafka 会不会将这个分区重新分配给另一个消费者并且消息会被双重处理？
-
当密钥未被引用时，如何进行 kafka rest api 调用？
-
等待每个人连接到卡夫卡（node-rdkafka）中新消费者组的主题
-
运行 没有指定分区的kafka消费者
-
Java - 通过特定 AvroSerde 的输入动态更改 Kafka 数据类型
-
分区处理卡住，直到在 Kafka Streams 中重新平衡期间重建状态存储
-
Except in thread "main" org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
-
KafkaConsumer 跨线程可见性
-
Confluent Control Center - 未列出消费者
-
Kafka 获取相应消息 ID 的分区 ID
-
来自 Kafka 消息的日志偏移量、分区和主题
-
来自主题的 KTable 和服务重启
-
Kafka Connect 手动 offset/commit 管理
-
Spring-Kafka：Consumer Group Rebalancing对Stateful Retry的影响
-
Kafka 消息发送到单个主题而不是 n 个重试主题和 dlt