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

kafka中不同主题的多个连接器都去同一个节点

张智
2023-03-14

我在kafka-连接中创建了两个kafka连接器,它们使用相同的连接器类,但它们听的主题不同。

当我在节点上启动进程时,两个连接器最终都会在此进程上创建任务。但是,我希望一个节点只处理一个连接器/主题。如何将主题/连接器限制为单个节点?我在connect-distributed.properties中没有看到任何配置,其中进程可以指定使用哪个连接器。

谢谢。

共有1个答案

明财
2023-03-14

分布式模式下的Kafka Connect可以作为一个或多个辅助角色的集群运行。每个辅助角色可以运行多个任务。根据您运行的连接器和辅助角色的数量,您将在同一个辅助角色上运行任务。这是经过深思熟虑的——这个想法是Kafka Connect将跨可用辅助角色为您管理您的任务和工作负载。

如果想要隔离处理,可以将Kafka Connect作为单独的连接集群运行,既可以在同一台机器上运行(确保使用不同的REST端口),也可以在不同的机器上运行。

有关更多信息,请参阅体系结构和配置以了解配置单独集群的步骤。请注意,集群实际上可以是一个工作机,但在发生故障时,您没有任何冗余。

 类似资料:
  • 我们有一个Kafka主题,有源源不断的数据。为了处理它,我们有一个无状态的Flink管道,它使用该主题并写入另一个主题。 我们是不是漏掉了什么?我们误会什么了吗?有没有更好的解决办法? 谢了!

  • 我想我需要为每个StreamListener方法单独的应用程序id,但是如果我正在监听相同的主题,我如何在application.yml文件中配置它呢?

  • 分布式模式下Kafka Connect集群的偏移管理行为是什么,即运行多个连接器并监听同一组主题(或一个主题)? 因此,在分布式模式下,Kafka Connect 会将偏移量信息存储在 Kafka 中,此偏移量将由集群中的工作线程读取和提交。如果我在该 Kafka Connect 集群中运行多个连接器侦听同一主题,会发生什么情况?分区的偏移量是否与所有连接器相同,或者每个连接器在分区上的偏移量是否

  • 我正在使用wurstmeister的docker-kafka项目在容器中运行kafka/zoomaster。我使用docker-comup将容器localhost作为变量。 我已经编写了一个Java应用程序,它使用flink连接并使用这个Kafka容器的一个主题。如果我导出一个可运行的罐子,并从我的机器上运行它,它绝对可以正常工作。当我创建下面的图像以从另一个docker容器运行jar时,我在线程

  • 如何以可伸缩的方式编写连接多个Kafka主题的使用者? 我有一个主题用一个键发布事件,第二个主题用相同的键发布与第一个主题的子集相关的其他事件。我想编写一个订阅这两个主题的使用者,并为出现在这两个主题中的子集执行一些额外的操作。 理想情况下,我需要将主题绑定在一起,以便以相同的方式对它们进行分区,并同步地将分区分配给使用者。我怎么能这么做? 我知道Kafka Streams将主题连接在一起,这样键

  • 在构建Kafka Streams拓扑时,可以通过两种不同的方式对多个主题的读取进行建模: 读取具有相同源节点的所有主题。 选项1相对于选项2是否有相对优势,反之亦然?所有主题都包含相同类型的数据,并具有相同的数据处理逻辑。