0

我一直在使用 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) 应用程序.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 上部署此应用程序？非常感激。

谢谢你。

4

1 回答 1

0

您可以在此处遵循 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 与 A​​WS MSK 一起使用，但我已经在 EC2 上成功部署并运行了 Spring Boot 应用程序，并且 Elastic Beanstalk 与 AWS MSK 集群通信。而且，在这样做的过程中，我遵循了官方的 AWS MSK 文档，它对我有用，（尽管AWS Elastic Beanstalk 无法访问 AWS MSK只是一个小问题）。

于 2020-02-20T06:37:47.910 回答