spring-kafka-test
-
创建名称为 'embeddedKafka' 的 bean 时出错：调用 init 方法失败
-
java.lang.NoClassDefFoundError: scala/collection/GenTraversableOnce at kafka.utils.TestUtils.tempDir(TestUtils.scala)
-
Spring Boot 和 Kafka 升级破坏了我的测试
-
java.lang.ClassNotFoundException: org.apache.jute.OutputArchive 使用最新的 spring-kafka 和 spring-kafka-test 2.5.2
-
嵌入式 Kafka 测试随机失败
-
聚合回复Kafka模板发布策略问题
-
spring 写入 customConsumerFactory 和 customKafkaListenerContainerFactory 时未自动加载 kafka 属性
-
Spring kafka 单元测试监听器未订阅主题
-
KStream to KTable Inner Join 每次处理相同数据时产生不同数量的记录
-
Kafka 流测试：java.util.NoSuchElementException：未初始化的主题："output_topic_name"
-
如何使用 EmbeddedKafkaRule/EmbeddedKafka 设置 Spring Kafka 测试来修复 TopicExistsException 间歇性错误？
-
如何为 Spring Kafka Listener 创建集成测试
-
EmbeddedKafka 不工作导致 Scala 错误
-
连接 Kafka 3.0 时遇到问题 - org.apache.kafka.common.KafkaException：无法加载 SSL 密钥库
-
如何使用 Kafka Streams 对 Spring Cloud Stream 进行单元测试
-
Spring 使用 Kafka 2 的嵌入式 Kafka。2.x
-
即使测试通过，在 Kafka 测试期间也会出现异常
-
不能在测试中多次使用 @KafkaListener
-
Spring 卡夫卡 (2.2.7.RELEASE) 用。 kafka-clients:2.2.1 嵌入式代理启动期间的 IOException
-
嵌入式 Kafka 以错误的分区数开始