Подключение к мск с помощью пружинной кафки - PullRequest
Новая
       86

Подключение к мск с помощью пружинной кафки

0 голосов
/ 27 января 2020

Привет! Я использую aws MSK и пытаюсь подключиться к нему с помощью Spring Kafka Client. При отправке сообщения в кластер kafka из моего кода я получаю следующую ошибку: 

2020-01-27 21:49:17.141 ERROR 4176 --- [nio-9000-exec-4] o.s.k.support.LoggingProducerListener    : Exception thrown when sending a message with key='key' and payload='payload' to topic topic1:

org.apache.kafka.common.errors.TimeoutException: Topic topic1 not present in metadata after 60000 ms.

Вот мой конфиг - 

spring:
  kafka:
    consumer:
      bootstrap-servers: {server}
      group-id: group_id
      auto-offset-reset: earliest
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
      ssl:
        trust-store-location: /tmp/kafka.client.truststore.jks
        key-store-location: /tmp/kafka.client.truststore.jks
        protocol: ssl
    producer:
      bootstrap-servers: {server}
      key-serializer: org.apache.kafka.common.serialization.StringSerializer
      value-serializer: org.springframework.kafka.support.serializer.JsonSerializer
      ssl:
        trust-store-location: /tmp/kafka.client.truststore.jks
        key-store-location: /tmp/kafka.client.truststore.jks
        protocol: ssl

Я могу подключиться к кластеру kafka (произвести и использовать сообщения), используя командную строку, выполнив следующие шаги: https://docs.aws.amazon.com/msk/latest/developerguide/produce-consume.html

topi c - topic1 существует, и я могу вывести его из командной строки

Пожалуйста, помогите.

...