spring-kafka
-
以编程方式配置侦听器而不是使用注释
-
多个 Spring Kafka Consumer 一个 class 多个组
-
无法将 Avro 特定记录反序列化为 Spring Cloud Stream 中的通用记录
-
如何将 "Kafka Streams Binder" 与 "Functional Style" 和 DI 一起使用？
-
Spring Cloud Stream DLQ 本机编码问题：有效负载不是字节 []
-
嵌入式 Kafka 以错误的分区数开始
-
Spring Kafka 模板根据不同情况发送重试
-
如何模拟 KafkaTemplate 的结果
-
为什么我只能看到这个 Kafka 示例中的所有其他消息？
-
创建 Kafka Producer 的演示应用程序抛出 "Failed to construct kafka producer" java.lang.InstantiationException 错误：null
-
Consumer Aware 调用消费者线程安全
-
Spring Cloud Stream 多主题事务管理
-
使用 Kafka binder 在 Spring Cloud Stream 中重播来自死信队列的消息
-
我们如何将 DeadLetterPublishingRecoverer 与 RetryTemplate 一起使用？
-
Reactor Kafka：Exactly Once 处理样本
-
如何测试使用 Avro 和 Confluent Schema Registry 的 Spring Cloud Stream Kafka Streams 应用程序？
-
Spring 引导 kafka 流没有正常终止
-
Reactor Kafka：ReactiveKafkaProducerTemplate
-
如何配置 Kafka 重复未提交的偏移量消息？
-
单元测试 KafkaMessageListenerContainer