spring 在创建EmbeddedKafka代理时，使用@EmbeddedKafka进行测试失败，并出现TimeoutException

b91juud3  于 2024-01-05  发布在  Spring
关注(0)|答案(1)|浏览(168)

从Spring-Boot 2.4 -> 2.7升级并升级Kafka 2.8.2 -> 3.6.1后，使用我的应用程序运行单元测试
我有这样的单元测试设置：

  1. @RunWith(SpringRunner.class)
  2. @SpringBootTest
  3. @WebAppConfiguration
  4. @DirtiesContext(classMode = DirtiesContext.ClassMode.BEFORE_EACH_TEST_METHOD)
  5. @ActiveProfiles("inmemory")
  6. @EmbeddedKafka(topics={"KafkaDataHelperNonSpyUnitTest.topic"}, //partitions = 3,
  7.                adminTimeout = 30)
  8. @TestPropertySource(value = "classpath:hsql-test.properties",
  9.                     properties = "spring.cache.type=NONE")
  10. public class KafkaDataHelperNonSpyUnitTest
  11. {
  12.   /*
  13.    * Setup Beans Here
  14.    */  
  16.    @Test
  17.    public void testGetConsumer()
  18.    {
  19.       Map<String, Object> props = new HashMap<>();
  20.       props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, embeddedBrokers);
  21.       props.put(ConsumerConfig.GROUP_ID_CONFIG, UUID.randomUUID().toString());
  22.       props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG,
  23.                 StringDeserializer.class);
  24.       props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
  25.       props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,
  26.                 StringDeserializer.class);
  27.       props.put(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, 5);
  29.       kafkaDataHelper.getConsumer("KafkaDataHelperNonSpyUnitTest.topic", props);
  30.    }
  31. }

字符串
测试失败，

  1. Failed to load ApplicationContext
  2. java.lang.IllegalStateException: Failed to load ApplicationContext
  3.     at org.springframework.test.context.cache.DefaultCacheAwareContextLoaderDelegate.loadContext(DefaultCacheAwareContextLoaderDelegate.java:98)
  4.     at org.springframework.test.context.support.DefaultTestContext.getApplicationContext(DefaultTestContext.java:124)
  5.     at org.springframework.test.context.web.ServletTestExecutionListener.setUpRequestContextIfNecessary(ServletTestExecutionListener.java:190)
  6.     at org.springframework.test.context.web.ServletTestExecutionListener.prepareTestInstance(ServletTestExecutionListener.java:132)
  7.     at org.springframework.test.context.TestContextManager.prepareTestInstance(TestContextManager.java:248)
  8.     at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.createTest(SpringJUnit4ClassRunner.java:227)
  9.     at org.springframework.test.context.junit4.SpringJUnit4ClassRunner$1.runReflectiveCall(SpringJUnit4ClassRunner.java:289)
  10.     at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
  11.     at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.methodBlock(SpringJUnit4ClassRunner.java:291)
  12.     at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:246)
  13.     at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:97)
  14.     at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
  15.     at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
  16.     at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
  17.     at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
  18.     at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
  19.     at org.springframework.test.context.junit4.statements.RunBeforeTestClassCallbacks.evaluate(RunBeforeTestClassCallbacks.java:61)
  20.     at org.springframework.test.context.junit4.statements.RunAfterTestClassCallbacks.evaluate(RunAfterTestClassCallbacks.java:70)
  21.     at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
  22.     at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
  23.     at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.run(SpringJUnit4ClassRunner.java:190)
  24.     at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.runTestClass(JUnitTestClassExecutor.java:110)
  25.     at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:58)
  26.     at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:38)
  27.     at org.gradle.api.internal.tasks.testing.junit.AbstractJUnitTestClassProcessor.processTestClass(AbstractJUnitTestClassProcessor.java:62)
  28.     at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:51)
  29.     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  30.     at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  31.     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  32.     at java.lang.reflect.Method.invoke(Method.java:498)
  33.     at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36)
  34.     at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
  35.     at org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:33)
  36.     at org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:94)
  37.     at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
  38.     at org.gradle.api.internal.tasks.testing.worker.TestWorker$2.run(TestWorker.java:176)
  39.     at org.gradle.api.internal.tasks.testing.worker.TestWorker.executeAndMaintainThreadName(TestWorker.java:129)
  40.     at org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:100)
  41.     at org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:60)
  42.     at org.gradle.process.internal.worker.child.ActionExecutionWorker.execute(ActionExecutionWorker.java:56)
  43.     at org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:133)
  44.     at org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:71)
  45.     at worker.org.gradle.process.internal.worker.GradleWorkerMain.run(GradleWorkerMain.java:69)
  46.     at worker.org.gradle.process.internal.worker.GradleWorkerMain.main(GradleWorkerMain.java:74)
  47. Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'embeddedKafka': Invocation of init method failed; nested exception is org.apache.kafka.common.KafkaException: java.util.concurrent.TimeoutException
  48.     at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1804)
  49.     at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:431)
  50.     at org.springframework.kafka.test.context.EmbeddedKafkaContextCustomizer.customizeContext(EmbeddedKafkaContextCustomizer.java:116)
  51.     at org.springframework.boot.test.context.SpringBootContextLoader$ContextCustomizerAdapter.initialize(SpringBootContextLoader.java:333)
  52.     at org.springframework.boot.SpringApplication.applyInitializers(SpringApplication.java:605)
  53.     at org.springframework.boot.SpringApplication.prepareContext(SpringApplication.java:374)
  54.     at org.springframework.boot.SpringApplication.run(SpringApplication.java:307)
  55.     at org.springframework.boot.test.context.SpringBootContextLoader.loadContext(SpringBootContextLoader.java:136)
  56.     at org.springframework.test.context.cache.DefaultCacheAwareContextLoaderDelegate.loadContextInternal(DefaultCacheAwareContextLoaderDelegate.java:141)
  57.     at org.springframework.test.context.cache.DefaultCacheAwareContextLoaderDelegate.loadContext(DefaultCacheAwareContextLoaderDelegate.java:90)
  58.     ... 43 more
  59. Caused by: org.apache.kafka.common.KafkaException: java.util.concurrent.TimeoutException
  60.     at org.springframework.kafka.test.EmbeddedKafkaBroker.createTopics(EmbeddedKafkaBroker.java:490)
  61.     at org.springframework.kafka.test.EmbeddedKafkaBroker.lambda$createKafkaTopics$8(EmbeddedKafkaBroker.java:477)
  62.     at org.springframework.kafka.test.EmbeddedKafkaBroker.doWithAdmin(EmbeddedKafkaBroker.java:573)
  63.     at org.springframework.kafka.test.EmbeddedKafkaBroker.createKafkaTopics(EmbeddedKafkaBroker.java:476)
  64.     at org.springframework.kafka.test.EmbeddedKafkaBroker.afterPropertiesSet(EmbeddedKafkaBroker.java:373)
  65.     at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1863)
  66.     at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1800)
  67.     ... 52 more
  68. Caused by: java.util.concurrent.TimeoutException
  69.     at java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784)
  70.     at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
  71.     at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:180)
  72.     at org.springframework.kafka.test.EmbeddedKafkaBroker.createTopics(EmbeddedKafkaBroker.java:487)
  73.     ... 58 more

型
那么，为什么在创建嵌入式Kafka Broker时测试会超时呢？
更重要的是，我该如何修复它？

更新：

相关的build.gradle依赖项片段

  1. buildscript
  2. {
  3.    ext { springBootVersion = '2.7.18' }
  5.    dependencies
  6.    {
  7.       classpath("org.springframework.boot:spring-boot-gradle-plugin:${springBootVersion}")
  8.    }
  9. }
  11. apply plugin: "org.springframework.boot"
  12. apply plugin: 'io.spring.dependency-management'
  14. dependencies
  15. {
  16.     // Spring Framework (Core)
  17.     def springFrameworkVersion = 5.3.27
  18.     implementation ('org.springframework:spring-core')
  19.     { version { strictly springFrameworkVersion } }
  20.     implementation ('org.springframework:spring-aop')
  21.     { version { strictly springFrameworkVersion } }
  22.     implementation ('org.springframework:spring-context')
  23.     { version { strictly springFrameworkVersion } }
  24.     implementation('org.springframework:spring-context-support')
  25.     { version { strictly springFrameworkVersion } }
  26.     implementation ('org.springframework:spring-beans')
  27.     { version { strictly springFrameworkVersion } }
  28.     implementation ('org.springframework:spring-messaging')
  29.     { version { strictly springFrameworkVersion } }
  30.     implementation ('org.springframework:spring-expression')
  31.     { version { strictly springFrameworkVersion } }
  33.     // Spring Framework (Data)
  34.     implementation('org.springframework:spring-jdbc')
  35.     { version { strictly springFrameworkVersion } }
  36.     implementation('org.springframework:spring-tx')
  37.     { version { strictly springFrameworkVersion } }
  39.     // Spring Framework (Web)
  40.     implementation ('org.springframework:spring-web')
  41.     { version { strictly springFrameworkVersion } }
  42.     implementation ('org.springframework:spring-websocket')
  43.     { version { strictly springFrameworkVersion } }
  44.     implementation ('org.springframework:spring-webmvc')
  45.     { version { strictly springFrameworkVersion } }
  46.     implementation ('org.springframework:spring-webflux')
  47.     { version { strictly springFrameworkVersion } }
  49.     implementation "org.springframework.boot:spring-boot-starter-web:${springBootVersion}"
  50.     testImplementation "org.springframework.boot:spring-boot-starter-test:${springBootVersion}"
  52.     // Spring Framework (Security)
  53.     def springSecurityVersion = '5.7.11'
  54.     implementation("org.springframework.security:spring-security-core")
  55.     { version { strictly springSecurityVersion } }
  56.     implementation("org.springframework.security:spring-security-web")
  57.     { version { strictly springSecurityVersion } }
  58.     implementation("org.springframework.security:spring-security-ldap")
  59.     { version { strictly springSecurityVersion } }
  60.     implementation("org.springframework.security:spring-security-crypto")
  61.     { version { strictly springSecurityVersion } }
  62.     testImplementation("org.springframework.security:spring-security-test")
  63.     { version { strictly springSecurityVersion } }
  65.     implementation "org.springframework.security.oauth:spring-security-oauth2:2.5.2.RELEASE"
  67.     implementation"org.springframework.boot:spring-boot-starter-actuator:${springBootVersion}"
  68.     implementation('org.springframework.retry:spring-retry:1.3.3')
  70.     runtimeOnly("org.springframework.boot:spring-boot-properties-migrator:${springBootVersion}")
  72.     // Kafka
  73.     def KafkaClientVersion = '3.6.1'
  74.     implementation('org.springframework.kafka:spring-kafka:')
  75.     { version { strictly('2.9.13') } }
  76.     testImplementation('org.springframework.kafka:spring-kafka-test')
  77.     { version { strictly('2.9.13') } }
  78.     implementation('org.apache.kafka:kafka-clients')
  79.     { version { strictly(KafkaClientVersion) } }
  80.     testImplementation('org.apache.kafka:kafka-streams')
  81.     { version { strictly(KafkaClientVersion) } }
  82.     implementation('org.apache.kafka:kafka-server-common')
  83.     { version { strictly(KafkaClientVersion) } }
  84.     testImplementation('org.apache.kafka:kafka-server-common')
  85.     { version { strictly(KafkaClientVersion) } }
  86.     implementation('org.apache.kafka:kafka-storage')
  87.     { version { strictly(KafkaClientVersion) } }
  88.     testImplementation('org.apache.kafka:kafka-tools')
  89.     { version { strictly(KafkaClientVersion) } }
  90.     testImplementation('org.apache.kafka:connect-json')
  91.     { version { strictly(KafkaClientVersion) } }
  92.     testImplementation('org.apache.kafka:connect-api')
  93.     { version { strictly(KafkaClientVersion) } }
  95.     testImplementation("org.apache.kafka:kafka_2.13:${KafkaClientVersion}:test")
  96. }

型

spring

1条答案

按热度按时间
qvtsj1bj

qvtsj1bj1#

在尝试了一堆东西之后。我最终转移到了一个不同的应用程序。遇到了同样的错误。
我找到的解决方案是从@EmbeddedKafka注解中删除主题名称。

赞(0）分享  回复(0）举报  2024-01-05
我来回答

相关问题

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新问答

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com