spring-kafka
-
当 ConcurrentKafkaListenerContainerFactory 中的一个消费者线程失败时会发生什么
-
在回调中发送记录时如何修复 spring-kafka 中的 'Failed to update metadata after xxx ms'
-
使用@KafkaListener 时以编程方式设置属性
-
Kafka消费者动态获取主题
-
Kafka 侦听器在 spring Spring Kafka 2.2 的引导应用程序启动之前变得活跃。3.RELEASE
-
没有为 springkafka-template 发送方法注册回调的机会
-
如何 运行 超过 1 个 ktable-ktable 应用程序实例在单个分区的 kafka 主题上加入 kafka 流应用程序？
-
任何可用于使用 Spring 云流 kafka-streams 创建 GlobalKTable 的示例？
-
Kafka监听器接收List<ConsumerRecord<String, String>>，是否可以消费？
-
Spring 领导者改变后，kafka 消费者不提交给 kafka 服务器
-
使用 Spring Kafka 反序列化来自同一 Kafka 主题的不同 JSON 负载
-
将 spring-kafka-test 更新为 2.2.x 但仍然使用带有 junit5 和 spring boot 2 的旧 kafka-client 1.1.1
-
使用@KafkaListener 时，我可以获取对底层 KafkaConsumer 的引用，因为我想读取 endOffsets
-
卡夫卡广播。如果组中唯一的消费者出现故障，如何知道消费者组的读取偏移量
-
如果所有经纪人都不可用，如何关闭 KStream
-
关于对多个主题使用@KafkaListener autoStartup = "false" 的问题
-
如果没有消息，则不调用使用@KafkaListener 注释的方法
-
Spring Kafka 线程命名约定
-
Kafka Streams - 消费者内存过载
-
KStream 将记录发送到多个流（不是分支）