我正在尝试为Apache Kafka构建一个自定义的MongoDb Sink连接器 . 我的SinkConnector配置如下：
name=mongodb-connect-sink
connector.class=MongodbSinkConnector
tasks.max=2
uri=mongodb://localhost:27017
databases.collections=Collection1,Collection2
topics=Topic1,Topic2
在连接器的 taskConfig() 方法中，我正在拆分集合和主题，并为每个任务设置1个集合和1个主题 . 但这似乎被覆盖了，并且所有指定的主题都被分配给所有任务 . 除了将它们注册为单独的连接器之外，还有什么方法可以防止这种情况吗？