小编Rai*_*Dan的帖子

我正在使用自定义的Kafka连接器（使用Kafka Connect的Java API用Java编写）从外部源提取数据并存储在主题中。我需要设置自定义分区策略。我了解可以通过设置属性在Kafka Producer中设置自定义分区程序。但是，此属性对于Kafka连接器似乎没有任何作用。如何配置Kafka Connect（我正在使用脚本来运行连接器）以使用编写的自定义？partitioner.classconnect-standalonePartitioner