Вложенное исключение - org.apache.kafka.common.errors.TimeoutException: истекло время ожидания при получении метаданных темы - PullRequest
Новая
       23

Вложенное исключение - org.apache.kafka.common.errors.TimeoutException: истекло время ожидания при получении метаданных темы

0 голосов
/ 04 июля 2019

Я пытаюсь реализовать ту же реализацию в моем Maven Spring Boot + Kafka приложении для Producer, после отправки данных оно достигает Azure Matrix, но упоминается об ошибке. Я получаю ошибку: 

2019-07-04 12:27:31.729  INFO 92607 --- [nio-8050-exec-2] c.g.k.service.KafkaPublisherService      : sending message='t'
2019-07-04 12:28:31.730 ERROR 92607 --- [nio-8050-exec-2] o.s.k.support.LoggingProducerListener    : Exception thrown when sending a message with key='null' and payload='Hi' to topic testhub:

org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.

А для потребителя при чистой сборке я получаю ниже упомянутую ошибку: 

2019-07-04 12:48:26.837  WARN 94752 --- [main] o.s.w.c.s.GenericWebApplicationContext: Exception encountered during context initialization - cancelling refresh attempt: org.springframework.context.ApplicationContextException: 
    Failed to start bean 'org.springframework.kafka.config.internalKafkaListenerEndpointRegistry'; nested exception is org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching topic metadata

Кафка: загрузочные серверы: myeventhubname.servicebus.windows.net:9093 идентификатор клиента: kafkaconsumer свойства: sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule требуется username = "$ ConnectionString" password = "myeventhubname Key" sasl.mechanism: PLAIN security.protocol: SASL_SSL потребитель: идентификатор группы: testhubconsumer свойства: spring.json: use.type.headers: false # value.default.type: com.protonforest.kafkademo.consumer.ConsumerMessage темы: подписчик: testhub

Кафка: загрузочные серверы: myeventhubname.servicebus.windows.net:9093 # client-id: kafkapublisher свойства: sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule требуется username = "$ ConnectionString" password = "myeventhubname key" sasl.mechanism: PLAIN security.protocol: SASL_SSL шаблон: тема по умолчанию: testhub режиссер: значение-сериализатор: com.protonforest.kafkademo.publishers.ProducerMessageSerializer

...