spring-boot - 如何使用 Spring Cloud Stream 从应用程序连接到 Kafka Mesos Framework？

Question

有了一个Mesos-Marathon集群和一个带有Spring Cloud Stream的Spring Boot应用程序，它使用来自Kafka的主题，我们现在想要将 Kafka 与 Mesos 集群集成。为此，我们要安装Kafka Mesos 框架。

现在我们有这样的 application.yml 配置：

---
spring:
  profiles: local-docker
  cloud:
      stream:
        kafka:
          binder:
            zk-nodes: 192.168.88.188
            brokers: 192.168.88.188
 ....

一旦我们安装了 Kafka Mesos 框架，

我们如何从 Spring Cloud Stream 连接到 kafka？

或更具体地说

配置会如何？

Answer 1

配置属性看起来不错。您的主机地址是否正确。有关 kafka binder 配置属性的更多信息，您可以参考这里：

https://github.com/spring-cloud/spring-cloud-stream/blob/master/spring-cloud-stream-docs/src/main/asciidoc/spring-cloud-stream-overview.adoc#kafka-specific-设置