embedded-kafka
-
如何在 spring 启动时向 EmbeddedKafka 发送具有特定偏移量的消息？
-
使用 EmbeddedKafka 的集成测试：ContainerTestUtil.waitForAssignment 抛出 Expected 1 but got 0 partitions
-
NoClassDefFoundError: scala/collection/convert/AsJavaExtensions
-
使用带有 MockSchemaRegistryClient 的 embeddedKafka 使用 Spring 云流 kafka 流创建测试时出现问题
-
Spring 来自 Kafka 主题的 Cloud Stream 反序列化无效 JSON
-
NPE 使用嵌入式 Kafka 测试 Kafka Producer
-
为 Kafka 提供什么价值 schema.registry.ssl.engine.factory.class
-
Embedded Kafka 测试结果失败，大括号添加到 Value
-
如何使用 fs2-kafka 从 embedded-kafka 读取数据
-
在具有自定义通道绑定的 spring 云流测试中使用嵌入式 Kafka
-
使用 EmbeddedKafka 时，为每个 Spock 规范重新加载应用程序上下文
-
使用 KafkaEmbedded 是否不能保证消息顺序？
-
在 Spring Cloud Stream 中使用嵌入式 Kafka 进行集成测试时，如何立即验证消息是否已被确认？
-
Kafka Streams：混搭 PAPI 和 DSL KTable 不共同分区
-
使用 Kafka Streams 的 Scala Embedded Kafka 中的生产者错误
-
使用 scalatest-embedded-kafka 集成测试 Flink 和 Kafka