Spring Cloud Stream with AWS MSK - 如何在 AWS 上使用和部署？

Question

我已经使用 Spring Cloud Stream 和 Kafka 有一段时间了。我有一个示例 SCS-Producer，它将数据抽出到输出主题。

下面是我的生产者代码：-

@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 和应用程序，一切正常。但是我现在需要在 EC2 集群上部署我的应用程序，而且我必须使用 AWS MSK（这也是为我的团队预置的）。

到目前为止，我一直在使用由 DevOps 工程师创建的管道，因此我从来没有真正自己集成任何东西，在这种情况下，我可以帮助我的文档或演示项目非常少，甚至没有。我非常困难，我需要你的帮助。任何人都可以帮助我访问页面或链接或任何资源，我可以在其中按照步骤 1. 在我的代码中包含预置的 AWS MSK 信息的所有配置信息，以便我可以在 AWS 上部署此应用程序？非常感谢。

谢谢。

Answer 1

您可以在此处https://docs.aws.amazon.com/msk/latest/developerguide/getting-started.html 遵循 AWS MSK 官方分步指南，然后使用在第 4 步中创建的相同 EC2 实例/机器来部署您自己的 Spring Cloud Stream 应用程序并对其进行测试。

如果按照指南，您能够按照步骤 #6 中所述生成和使用数据，那么您的 Spring Cloud Stream 应用程序也应该能够连接。

我之前没有将 Spring Cloud Stream 与 A​​WS MSK 一起使用，但我已经在 EC2 上成功部署并运行了 Spring Boot 应用程序，并且 Elastic Beanstalk 与 AWS MSK 集群通信。而且，在这样做的过程中，我遵循了 AWS MSK 官方文档，它对我有用（尽管AWS Elastic Beanstalk unable to access AWS MSK 只是一个小问题）。