@Embeddedkafka тестирование в Spring Boot ⇐ JAVA

[Anonymous]

При запуске этого тестового класса я получаю:
org.apache.kafka.common.KafkaException: Failed to construct kafka consumer

at org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer.(LegacyKafkaConsumer.java:265)
at org.apache.kafka.clients.consumer.internals.ConsumerDelegateCreator.create(ConsumerDelegateCreator.java:65)
at org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:600)
at org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:595)
at org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:543)
at com.lwo.tstlab.testproject.ControllerTest.testControllerSentMessage(ControllerTest.java:42)
at java.base/java.lang.reflect.Method.invoke(Method.java:578)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
Caused by: org.apache.kafka.common.config.ConfigException: No resolvable bootstrap urls given in bootstrap.servers
at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:103)
at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:62)
at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:58)
at org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer.(LegacyKafkaConsumer.java:184)
... 8 more
< /code>
Я предполагаю, что проблема в том, что я не добавил сервер начальной загрузки в конфигурацию потребителя. Я должен немедленно отметить, что я специально пытаюсь создать локальный экземпляр потребителя, потому что моему приложению не нужно настроить потребитель @bean на уровне контекста, оно только очереди сообщения. Я также попытался внедрить встраивание бобов в Embeddedkafkabroker , но я получаю: не могу Autowire. Не найдено бобов «embeddedkafkabroker». попадает в тему по запросу контроллера. Вот мой простой тестовый класс: < /p>
@EmbeddedKafka(topics = {"messages"})
@SpringBootTest
@AutoConfigureMockMvc
@EnableKafka
public class ControllerTest {

@Autowired
private MockMvc mockMvc;

@Test
public void testControllerSentMessage() throws Exception {
mockMvc.perform(MockMvcRequestBuilders.get("/api/orders/kafka"))
.andExpect(status().isCreated());
Map configProps = new HashMap();
configProps.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
configProps.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, JsonDeserializer.class);
ConsumerRecord received = KafkaTestUtils.getSingleRecord(new KafkaConsumer(configProps), "messages");
System.out.println(received.value().getText());
assertEquals("test", received.value().getText());
}
}


Подробнее здесь: https://stackoverflow.com/questions/793 ... pring-boot