@EmbeddedKafka пытается зарегистрировать AppInfo несколько раз? - PullRequest
Новая
       20

@EmbeddedKafka пытается зарегистрировать AppInfo несколько раз?

0 голосов
/ 01 октября 2019

У меня есть несколько интеграционных тестов с использованием @EmbeddedKafka, и после перехода на более новую версию 2.1.8 Springboot. RELEASE, журналы заполняются этими трассировками стека. Есть идеи, что может вызвать это? 

javax.management.InstanceAlreadyExistsException: kafka.server:type=app-info,id=0
    at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:437)
    at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1898)
    at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:966)
    at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
    at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
    at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
    at org.apache.kafka.common.utils.AppInfoParser.registerAppInfo(AppInfoParser.java:62)
    at kafka.server.KafkaServer.startup(KafkaServer.scala:321)
    at kafka.utils.TestUtils$.createServer(TestUtils.scala:132)
    at kafka.utils.TestUtils.createServer(TestUtils.scala)
    at org.springframework.kafka.test.EmbeddedKafkaBroker.afterPropertiesSet(EmbeddedKafkaBroker.java:223)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1837)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1774)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:405)

1 Ответ

0 голосов
/ 01 октября 2019

Если вы используете тесты Spring Test Context (@RunWith(SpringRunner.class), @SpringJUnitConfig, @SpringBootTest и т. Д.), То встроенная kafka сохраняется в контексте приложения.

Добавьте @DirtiesContext к каждому классу теста, чтобы экземпляр былутилизируется надлежащим образом.

...