如何在 Kafka Source Connector 中创建多个任务？

Question

我是 Apache Kafka 的新手，我正在尝试创建多个任务，每个任务都有不同的用途。但是源连接器方法taskClass()returns只有1个任务class。那么如何创建更多？

Answer 1

使用您需要的插件部署多个连接器实例。您也 low-level 查看 taskClass() 等。如果您无法使用单个连接器配置从多个源获取数据，只需创建其他连接器配置。每个只是配置文件。一个连接器 = 一项任务（或更多，如果向外扩展）。