当前位置: 首页 > 知识库问答 >
问题:

如何使用Spring云流从应用程序连接到Kafka·梅索斯框架?

端木皓君
2023-03-14

有一个Mesos-Marthon集群和一个带有Spring Cloud Stream的Spring Boot应用程序,它使用来自Kafka的主题,我们现在希望将Kafka与Mesos集群集成。为此,我们要安装Kafka Mesos Framework。

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

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

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

我们怎么从春云流连接Kafka

或者更具体地说

配置将如何?

共有1个答案

海宁
2023-03-14

配置属性看起来不错。您的主机地址正确吗。有关kafka活页夹配置属性的更多信息,请参阅:

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

 类似资料:
  • 我有一个Spring boot应用程序,里面有一个非常简单的Kafka制作人。如果我在没有加密的情况下连接到Kafka集群,一切都会很好。但如果我尝试使用SSL连接到kafka群集,就会超时。在producer中是否需要其他配置,或者需要定义其他属性,以允许spring正确使用所有配置? 我有以下属性设置: 应用程序启动时,将以下结果打印为ProducerConfig: 我的制作人非常简单: 使用

  • 我试图将我的spring应用程序连接到debezium/kafka:0.10,但没有成功。最初应用程序使用Wurstmeister/kafka图像,但现在我引入了debezium的一个新功能,并且希望两者只使用一个kafka图像。我不能把应用程序连接到debezium kafka或debezium连接到wurstmeister kafka。有人知道这两个图像是否都可以使用一个图像?欢迎任何想法:)

  • 我正在使用处理器 API 对状态存储进行一些低级处理。关键是我还需要在存储到商店后写入主题。如何在Spring Cloud Streams Kafka应用程序中完成?

  • 免责声明:我知道人们通常不会这样做,我使用SQL数据库是出于成本原因,而且我对编程比较陌生。 我正在尝试从我的Android Studio应用程序向我的MariaDB数据库发送SQL脚本。我目前正在为MariaDB实现一个Java数据库连接(JDBC)驱动程序,但我不确定需要包括什么。 我去了JDBC MariaDB驱动程序的下载网站,但是有很多jar文件,我可以选择下载。你怎么知道你需要哪一个,

  • 我有一个大型Sybase ASE C/C应用程序,我想将其迁移到Postgresql。应用程序使用的是Sybase CT库(没有什么复杂的:简单的SQL,很少批量上传等)。应用程序是使用SYBASE OCS-16在Linux上构建和运行的。 我正在尝试评估BabelFish扩展是否有助于加快迁移。 第一个挑战(从Sybsae迁移)是应用程序广泛使用多语句查询来返回多结果集,使用动态生成的Trans