Как подключиться из проекта Spring Boot kafka к aws MSK - PullRequest
Новая
       40

Как подключиться из проекта Spring Boot kafka к aws MSK

0 голосов
/ 18 июня 2020

Я пытаюсь подключиться к кластеру aws msk из приложения Spring Boot Kafka.

У меня есть aws msk arn, доступна конфигурация сервера boot strap.

Как интегрироваться в приложении? Любые примеры

Могу ли я запустить его из локального, то есть подключиться к AWS MSK из локального экземпляра приложения

msk cluster

Ответы [ 2 ]

1 голос
/ 19 июня 2020

Подключение к AWS MSK похоже на подключение к любому кластеру Kafka.

Это зависит от того, как вы настроили свой MSK? (VP C - Su bnet) Проверьте, есть ли у вас доступ со своего локального компьютера или вам нужно использовать VPN.

Также посмотрите, как настроены и доступны конечные точки ваших брокеров - Пример:

  • Открытый текст (брокер: 9092)
  • TLS (брокер: 9094)

Если это открытый текст, это так же просто, как установить bootstrap .servers.

В противном случае вам необходимо добавить указанные ниже свойства для доступа к вашему кластеру MSK. 

security.protocol: SSL
ssl.truststore.location: jks
ssl.truststore.password: pwd

Пожалуйста, дайте мне знать, если у вас останутся вопросы.

0 голосов
/ 19 июня 2020

Если вы можете подключиться с помощью команд kafka-console-* (или проще, kafkacat), то вы сможете подключиться из любого другого приложения.

Я предлагаю вам отладить с помощью этих инструментов, прежде чем запускать что-либо еще.

...