如何使用@EmbeddedKafka Annotation（junit5）设置adminTimeout值？

Question

同时使用并行 gradle 测试 (org.gradle.parallel=true) 以最小化使用 junit5 和 @EmbeddedKafka 注释的总体测试执行时间（我需要对 > 20 个不同的 kafka 进行集成测试基于微服务；使用并行测试允许我将执行时间除以 10 倍），我开始尝试超时异常作为 EmbeddedKafkaBroker 的 createTopics 方法的一部分。
通过为 EmbeddedKafkaBroker 的 adminTimeout 成员设置自定义值可以轻松解决此问题...问题是我在使用 junit5 和@EmbeddedKafka 注释时看不到如何实现此目的...有什么建议吗？
非常感谢您的专业知识和时间。
最好的问候

Answer 1

EmbeddedKafkaBroker的方法：

/**
 * Set the timeout in seconds for admin operations (e.g. topic creation, close).
 * Default 30 seconds.
 * @param adminTimeout the timeout.
 * @since 2.2
 */
public void setAdminTimeout(int adminTimeout) {

只是没有暴露在@EmbeddedKafka。

欢迎提出 GH 问题，我们会考虑在未来添加它。

作为解决方法，您可以手动设置此类嵌入式代理： private static EmbeddedKafkaBroker embeddedKafka;

@BeforeAll
static void setup() {
    embeddedKafka = new EmbeddedKafkaBroker(1, true, topic1, topic2);
    embeddedKafka.setAdminTimeout(100);
    embeddedKafka.afterPropertiesSet();
}

@AfterAll
static void tearDown() {
    embeddedKafka.destroy();
}

如何使用@EmbeddedKafka Annotation（junit5）设置adminTimeout值？

how to set adminTimeout value with @EmbeddedKafka Annotation (junit5)?

spring-kafka

spring-kafka-test