spring-kafka-test
-
KafkaMessageChannelBinder 无法转换为 class TestSupportBinder
-
测试无法开始使用 spring-kafka-test (NoClassDefFoundError)
-
KafkaTestUtils.getRecords() 或 KafkaTestUtils.getSingleRecord() 有时花费的时间太长
-
如何使用@EmbeddedKafka Annotation（junit5）设置adminTimeout值？
-
EmbeddedKafka 自 Spring Boot 2.6.X 失败：AccessDeniedException: ..\AppData\Local\Temp\spring.kafka*
-
Spring KafkaTestUtils：等待主题中的消息被消费
-
如何在 spring 启动时向 EmbeddedKafka 发送具有特定偏移量的消息？
-
升级到 Spring 启动到 2.5.5 会导致 kafka 库出现问题
-
Spring 启动嵌入式kafka抛出错误BeanCreationException
-
ClassNotFoundException：scala.collection.convert.AsJavaExtensions 使用来自 spring-kafka-test 的 @EmbeddedKafka 时
-
如何在测试期间启动嵌入式 kafka 集群？
-
嵌入式 Kafka 上的空点异常
-
Kafka 事务生产者抛出 'Timeout expired while initializing transactional state in 60000ms'
-
如何使用 Junit 测试 Kafka OnFailure 回调？
-
嵌入式 Kafka 测试 - 不调用 Kafka 侦听器
-
添加jsonschema2pojo-core后嵌入式Kafka测试用例报错
-
使用 "consume-transform-produce" 集成测试的 Kafka exactly once 消息传递测试
-
如何使用 spring-boot EmbeddedKafka 对 KStream 拓扑进行集成测试？
-
如何包装由 seekToCurrentErrorHandler 处理的 @KafkaListener 和用于测试的闩锁
-
测试 @KafkaListener 的 Spring Kafka 错误处理程序时出现异常