如何在 Kafka 源连接器中创建多个任务



我是Apache Kafka的新手,我正在尝试创建多个任务,每个任务都有单独的目的。但源连接器方法taskClass()仅返回 1 个任务类。那么我该如何创造更多?

使用所需的插件部署多个连接器实例。你看taskClass()太低了。如果无法使用单个连接器配置从多个源获取数据,只需创建其他连接器配置即可。每个都只是配置文件。一个连接器 = 一个任务(如果横向扩展,则为多个任务(。

相关内容

  • 没有找到相关文章

最新更新