EmbeddedKafka потребляет сообщение вызывает java .util.concurrent.TimeoutException - PullRequest
Новая
       48

EmbeddedKafka потребляет сообщение вызывает java .util.concurrent.TimeoutException

0 голосов
/ 16 апреля 2020

Я пытаюсь использовать EmbeddedKafka с проектом scala для модульного тестирования. Модуль, который я хочу протестировать, является производителем сообщений. В моем тестовом классе я запустил встроенную версию следующим образом: 

implicit val config: EmbeddedKafkaConfig =
    EmbeddedKafkaConfig(kafkaPort = 7000, zooKeeperPort = 7001)
EmbeddedKafka.start()
EmbeddedKafka.createCustomTopic("test")

Затем я вызываю свой метод для создания метода для "test" topi c, используя "kafka. bootstrap .servers" to " локальный: 7000" . В моем тестовом методе я пытаюсь использовать сообщение таким образом - 

val consumedString = EmbeddedKafka.consumeFirstStringMessageFrom("test")

Это приводит к ошибке - 

java.util.concurrent.TimeoutException: Unable to retrieve 1 message(s) from Kafka in 5 seconds
    at net.manub.embeddedkafka.ops.ConsumerOps$$anonfun$1.apply(ConsumerOps.scala:242)
    at net.manub.embeddedkafka.ops.ConsumerOps$$anonfun$1.apply(ConsumerOps.scala:220)

Есть идеи, что здесь не так? Есть ли какие-либо настройки тайм-аута, которые я должен настраивать, или я не использую встроенную кафку должным образом?

Цените любые входные данные! спасибо.

...