spring-kafka
-
@StreamListener 在 ApplicationRunner 运行 执行之前开始消费
-
Spring 云流kafka事务配置
-
SeekToCurrentErrorHandler + ExponentialBackOff 将在 backOff 过去后记录错误，这是故意的吗？
-
Kafka消费者在心跳失败后离开群组
-
Kafka 分区为空
-
MessageListenerContainer 的指标方法未捕获正确的值
-
Kafka ConsumerInterceptor 所需的配置
-
有没有办法在 DeadLetterPublishingRecoverer 中找到消费者组？
-
基于kafka事件更新内存中的静态地图？
-
Kafka Spring 批量消费者 - 提交单个偏移量
-
如何在 SCDF 任务中使用 KafkaItemReader 获取完整消息？
-
如何包装由 seekToCurrentErrorHandler 处理的 @KafkaListener 和用于测试的闩锁
-
使用 spring-kafka 部署我的批处理消费者时获取 java.lang.ClassCastException
-
Apache Kafka - 基于 REST API 的消费者？
-
测试 @KafkaListener 的 Spring Kafka 错误处理程序时出现异常
-
IllegalStateException：请考虑在值 and/or 键解串器中配置一个 'ErrorHandlingDeserializer'
-
Spring Kafka：ReplyingKafkaTemplate 回复的 C++ 生产者
-
KafkaException: class 不是 org.apache.kafka.common.serialization.Deserializer 的实例
-
可用：预计至少有 1 个符合自动装配候选条件的 bean
-
Spring 5.X 使用 xml 配置的 Web Kafka 集成（不是 Spring 启动）