Spring Cloud Stream с AWS MSK - Как я могу использовать и развертывать на AWS? - PullRequest
Новая
       81

Spring Cloud Stream с AWS MSK - Как я могу использовать и развертывать на AWS?

0 голосов
/ 17 февраля 2020

Я уже некоторое время использую Spring Cloud Stream с Kafka. У меня есть пример SCS-Producer, который выкачивает данные на выход topi c.

Ниже приведен код моего производителя: - 

@EnableBinding(Source.class)
public class SampleProducer {


      @InboundChannelAdapter(value = Source.OUTPUT, poller = @Poller(fixedDelay = "7000", maxMessagesPerPoll = "1"))
public Employee MessageSource() {

Employee emp = new Employee();
emp.setName("Jack");
emp.setType("Dev");

return emp;
}
}

2) App.yml 

spring:
  cloud:
    stream:
      defaultBinder: kafka
      bindings:
        output:
          destination: topic1
          content-type: application/json
      kafka:
        binder:
          brokers: someIp:somePort
          zkNodes: someIp:somePort
server:
  port: 0

Запрос: - Никогда не развертывал AWS Приложение, которое использовало AWS Собственные сервисы. В приведенном выше коде все работает нормально, если я использую Kafka и приложение на моем Local. НО мне теперь нужно развернуть мое приложение в кластере EC2, а также я должен использовать AWS MSK (это также предусмотрено для моей команды).

Я до сих пор использовал конвейеры, созданные инженерами DevOps до сих пор. так что я никогда ничего не интегрировал сам по себе, и в этой ситуации очень мало или, скорее, нет документации или демонстрационных проектов. Я очень застрял, и мне нужна ваша помощь. Может ли кто-нибудь помочь мне перейти на страницу, ссылку или любой ресурс, на котором я могу выполнить шаги, чтобы 1. иметь всю информацию о конфигурации для предоставленной информации AWS MSK в моем коде, чтобы я мог развернуть это приложение на AWS? Очень признателен.

Спасибо.

Ответы [ 2 ]

0 голосов
/ 07 марта 2020

Есть ли у вас пример стартового кода, если вы заставили ваше приложение работать? Я тоже хочу создать подобное приложение.

0 голосов
/ 20 февраля 2020

Вы можете следовать официальному пошаговому руководству AWS MSK здесь https://docs.aws.amazon.com/msk/latest/developerguide/getting-started.html, а затем использовать тот же экземпляр / компьютер EC2, созданный на шаге # 4, для развертывания собственного Spring Cloud Stream. приложение и проверить его.

Если, следуя руководству, вы сможете производить и потреблять данные, как указано в шаге № 6, то ваше приложение Spring Cloud Stream также должно иметь возможность подключаться.

Я не использовал Spring Cloud Stream с AWS MSK раньше, но я успешно развернул и запустил приложения Spring Boot на EC2 и Elasti c Beanstalk, общаясь с AWS MSK кластерами. И при этом я следовал официальной документации AWS MSK, и она работала для меня (хотя с одним икотом AWS Elasti c Beanstalk не мог получить доступ AWS MSK ).

...