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

Question

我已经在Kafka上使用Spring Cloud Stream已有一段时间了。我有一个样本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 Native Services的AWS Application。在上面的代码中，如果我在本地计算机上使用Kafka和该应用程序，则一切正常。但是，我现在需要在EC2群集上部署我的应用程序，并且还必须使用AWS MSK（这也是我的团队所准备的）。

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

谢谢。

Answer 1

您可以在此处[A0]遵循AWS MSK官方分步指南，然后使用在步骤4中创建的相同EC2实例/计算机来部署您自己的Spring Cloud Stream应用并对其进行测试。

如果通过遵循指南，您能够按照步骤＃6的方式产生和使用数据，那么您的Spring Cloud Stream应用程序也应该也可以连接。

以前我没有将Spring Cloud Stream与AWS MSK一起使用，但是我已经在与AWS MSK集群通信的EC2和Elastic Beanstalk上成功部署并运行了Spring Boot应用程序。而且，这样做的时候，我遵循了官方的AWS MSK文档，它为我工作（尽管https://docs.aws.amazon.com/msk/latest/developerguide/getting-started.html只是打h了）。