Spring Kafka集成测试写入高水位文件时出错
我正在使用Spring Boot应用中的spring-kaka-2.2.0编写集成测试，虽然我的测试用例几乎成功了，但仍然会看到多个错误。 2019-02-21 11:12:35.434 ERROR 5717 --- [ Thread-7] kafka.server.Replic...
EmbeddedKafka在Spring Boot 2.6.X中失败：AccessDeniedException：..\AppData\Local\Temp\spring.kafka*
e: 通过Spring Boot 2.6.5已经修复此问题(参见https://github.com/spring-projects/spring-boot/issues/30243)自从升级到Spring Boot 2.6.X（我的情况是：2.6.1），我有多个项目在Windows上无法启动...
如何修复嵌入式Kafka找不到meta.properties文件的错误
我正在为使用kafka、kafka-streams和cassandra的应用程序尝试进行集成测试。但是当我尝试设置测试类时，出现了两个错误： ERROR [main] BrokerMetadataCheckpoint: Failed to read meta.properties file u...
嵌入式Kafka结合ContainerTestUtils.waitForAssignment会抛出：期望1个分区但实际得到0个分区
我们有一个集成测试，在该测试中，我们使用EmbeddedKafka向一个主题发出消息，我们的应用程序处理该消息，并将结果发送到第二个主题，我们从中消费并断言输出。在CI中，这可能有效2/3的时间，但是我们会遇到KafkaTestUtils.getSingleRecord抛出java.lang....
Spring KafkaListener: 如何知道何时准备就绪
我有一个简单的Spring Boot应用程序，它从Kafka读取并写入Kafka。我编写了一个使用EmbeddedKafka的SpringBootTest来测试所有这些内容。 主要问题是：有时测试会失败，因为测试发送Kafka消息太早了。这样，消息已经写入Kafka，而Spring应用程序（...
Kafka 流测试：java.util.NoSuchElementException: 未初始化的主题："output_topic_name"
我已根据https://kafka.apache.org/24/documentation/streams/developer-guide/testing.html编写了一个kafka流应用程序的测试类，代码如下： import com.EventSerde; import org.apac...