我是Apache Kafka的新手,我正在尝试创建多个任务,每个任务都有单独的目的。但源连接器方法taskClass()
仅返回 1 个任务类。那么我该如何创造更多?
使用所需的插件部署多个连接器实例。你看taskClass()
太低了。如果无法使用单个连接器配置从多个源获取数据,只需创建其他连接器配置即可。每个都只是配置文件。一个连接器 = 一个任务(如果横向扩展,则为多个任务(。