我已经成功地为confluent 3.2.x（kafka 0.10.x）上的kafka连接接收器使用了一个用java编写的简单自定义分区器类。我想升级到confluent 4.1（kafka 1.1）并且遇到错误。
kafkaconnect的插件加载机制似乎在cp3.3.0中发生了变化。以前，只有classpath选项，但是在cp3.3.0+中有一个更新的和推荐的选项 plugin.path 机制。
如果我尝试继续使用遗留类路径插件机制，当我尝试使用我的插件时，我会得到：

java.lang.ClassNotFoundException: io.confluent.connect.storage.partitioner.DefaultPartitioner

这是一个cp内部类。对于旧的cp3.2.x，它在类路径上是可用的，但是对于cp>=3.3.0中的新类路径隔离工作，我认为它必须与插件一起提供。
我想换成新的是明智的 plugin.path 机制。我删除类路径条目。默认情况下 /etc/kafka/connect-distributed.properties ，我明白了 plugin.path=/usr/share/java ，所以我将plugin.jar安装到 /usr/share/java/my-custom-partitioner/my-custom-partitioner.jar . 我也尝试过添加和不添加dependency.jar文件。
我的插件似乎在kafka connect服务启动时加载：

INFO Loading plugin from: /usr/share/java/my-custom-partitioner (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)
INFO Registered loader: PluginClassLoader{pluginLocation=file:/usr/share/java/my-custom-partitioner/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)

当我这样做时：

curl -X PUT -H "Content-Type: application/json" --data-binary "@sink_test_1.json" my-dev-test-vm:8083/connectors/sink-test-1/config

我得到：

{"error_code":500,"message":null}%

我可以在kafka connect系统日志中看到：

java.lang.NullPointerException
at io.confluent.connect.storage.partitioner.PartitionerConfig.classNameEquals(PartitionerConfig.java:270)
at io.confluent.connect.storage.partitioner.PartitionerConfig.access$000(PartitionerConfig.java:33)
at io.confluent.connect.storage.partitioner.PartitionerConfig$PartitionerClassDependentsRecommender.visible(PartitionerConfig.java:238)
at org.apache.kafka.common.config.ConfigDef.validate(ConfigDef.java:617)
at org.apache.kafka.common.config.ConfigDef.validate(ConfigDef.java:625)
at org.apache.kafka.common.config.ConfigDef.validate(ConfigDef.java:525)
at org.apache.kafka.common.config.ConfigDef.validateAll(ConfigDef.java:508)
at org.apache.kafka.common.config.ConfigDef.validate(ConfigDef.java:490)
at org.apache.kafka.connect.connector.Connector.validate(Connector.java:133)

不清楚出了什么问题，也不清楚为什么我的partitioner类加载不正确。
仅供参考，我已经用cp4.1+kafka1.1依赖性重新构建了我的java插件，并进行了一些小的更新，以匹配api的更改，比如为 getSchemaGeneratorClass 去我的分区班。