Тайм-аут из-за отсутствия темы при запуске теста весенней загрузки с помощью @EmbeddedKafka ⇐ JAVA

[Anonymous]

Я пытаюсь запустить интеграционный тест по следующему руководству https://www.baeldung.com/spring-boot-kafka-testing и получаю сообщение об ошибке:

Код: Выделить всё

org.springframework.kafka.KafkaException: Send failed

at org.springframework.kafka.core.KafkaTemplate.doSend(KafkaTemplate.java:815)
at org.springframework.kafka.core.KafkaTemplate.observeSend(KafkaTemplate.java:773)
at org.springframework.kafka.core.KafkaTemplate.send(KafkaTemplate.java:551)
at com.baeldung.kafka.embedded.EmbeddedKafkaIntegrationTest.givenEmbeddedKafkaBroker_whenSendingWithDefaultTemplate_thenMessageReceived(EmbeddedKafkaIntegrationTest.java:48)
at java.base/java.lang.reflect.Method.invoke(Method.java:580)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1597)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1597)
Caused by: org.apache.kafka.common.errors.TimeoutException: Topic testtopic1 not present in metadata after 60000 ms.

Тот же тест был успешно проведён на компьютере моего коллеги. Я просмотрел кучу вопросов, связанных с одной и той же ошибкой, но ни один из них не помог. Подскажите пожалуйста, что еще можно проверить.
P.S. полный лог здесь https://github.com/kinderproc/embedded_ ... ain/Custom -Errors.txt
ОБНОВЛЕНИЕ:
Я попытался увеличить время ожидания на случай, если у Кафки закончится время. Так как при отправке сообщения в очередь производителем возникает ошибка, я увеличил значение соответствующего параметра в настройках производителя, в application.yml.

Код: Выделить всё

spring:
kafka:
producer:
properties[max.block.ms]: 300000

К сожалению, это не помогло. Ошибка все та же.


Что интересно, название темы в сообщении об ошибке — «topic1», но я ожидаю увидеть «embedded-test-topic» из application.yml. Похоже, название темы взято не из application.yml, а из application.properties.

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