我正在尝试构建一条管道，在其中我必须将二进制数据从卡夫卡主题移动到kinesis流，但没有变换。因此，我计划将 ByTearrayConverter 用于Worker属性设置。但是我会收到以下错误！尽管我可以在此处看到bytearrayconverter类
在0.11.0版本上。我在3.2.x下找不到同一类：(
任何帮助将不胜感激。
key.converter=io.confluent.connect.replicator.util.ByteArrayConverter
value.converter=io.confluent.connect.replicator.util.ByteArrayConverter
Exception in thread "main" org.apache.kafka.common.config.ConfigException: Invalid value io.confluent.connect.replicator.util.ByteArrayConverter for configuration key.converter: Class io.confluent.connect.replicator.util.ByteArrayConverter could not be found.
at org.apache.kafka.common.config.ConfigDef.parseType(ConfigDef.java:672)
at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:418)
at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:55)
at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:62)
at org.apache.kafka.connect.runtime.WorkerConfig.<init>(WorkerConfig.java:156)
at org.apache.kafka.connect.runtime.distributed.DistributedConfig.<init>(DistributedConfig.java:198)
at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:65)
org.apache.kafka.connect.converters.bytearrayconverter仅添加到apache kafka 0.11(汇合3.3(中。如果您要早于3.3运行Contruent发行版，则需要Contruent Enterprise发行版(不是Confluent开源(并使用io.confluent.connect.connect.replicator.util.bytearrayconverter Converter