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

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

Сообщение 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_ ... Errors.txt

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

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «JAVA»