spring-kafka
-
使用 reactor Kafka 从主题读取消息并将消息批量写入 REST 端点
-
反应式 Kafka 项目中的多个 Kafka 配置
-
Kafka 在 Consumer.Poll(Duration.ZERO) 之后没有分配分区；
-
通过工厂方法实例化 Bean 失败；异常 org.springframework.beans.BeanInstantiationException
-
我可以使用 spring-kafka RecoveringBatchErrorHandler 来处理反序列化异常吗？
-
在 ReactiveKafkaProducerTemplate 发送方法中模拟 SenderResult
-
Spring Kafka 事务提交顺序
-
Spring Kafka 消费者的 CommitFailedException
-
Kafka - 消费者承诺的偏移量在应用程序停止时关闭 + 从过去提交偏移量
-
BATCH 与 MANUAL 和 ack 与 commit
-
映射类型和列表
-
Kafka 消费者 ClassNotFoundException
-
ConcurrentKafkaListenerContainerFactory 是否增加了消费来自 Kafka 主题的消息的并行度
-
嵌入式 Kafka 上的空点异常
-
如何在 Gradle/Spring Boot/Kotlin 应用程序中为单元、集成和端到端测试设置不同的文件夹？
-
Spring Cloud Stream 数据库事务不回滚
-
无法将 class org.json.JSONObject 的值转换为 class org.apache.kafka.common.serialization.StringSerializer/ JsonSerializer
-
使用带有手动计数器增量的千分尺定时器
-
Spring Cloud Kafka Streams 中的错误处理
-
使用 Spring Cloud Stream 生成多个主题时的 DLQ、有界重试和 EOS