无法运行connect-distributed.sh

Question

当我执行命令时，我得到了下面的错误。我的kafka消息没有流向hdfs

/bin/connect-Distributed.shQuickStart/kafka- /etc/schema-registry/connect-avro-distributed.properties /quickstart-hdfs.properties

 ERROR Failed to start task local-file-source-0 (org.apache.kafka.connect.runtime.Worker:456)
org.apache.kafka.common.config.ConfigException: Invalid value io.confluent.kafka.serializers.subject.TopicNameStrategy for configuration key.subject.name.strategy: Class io.confluent.kafka.serializers.subject.TopicNameStrategy could not be found.
        at org.apache.kafka.common.config.ConfigDef.parseType(ConfigDef.java:718)
        at org.apache.kafka.common.config.ConfigDef$ConfigKey.<init>(ConfigDef.java:1063)
        at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:148)
        at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:168)
        at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:207)
        at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:369)
        at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:382)
        at io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig.baseConfigDef(AbstractKafkaSchemaSerDeConfig.java:153)
        at io.confluent.connect.avro.AvroConverterConfig.<init>(AvroConverterConfig.java:27)
        at io.confluent.connect.avro.AvroConverter.configure(AvroConverter.java:63)
        at org.apache.kafka.connect.runtime.isolation.Plugins.newConverter(Plugins.java:263)
        at org.apache.kafka.connect.runtime.Worker.startTask(Worker.java:434)
        at org.apache.kafka.connect.runtime.distributed.DistributedHerder.startTask(DistributedHerder.java:865)
        at org.apache.kafka.connect.runtime.distributed.DistributedHerder.access$1600(DistributedHerder.java:110)
        at org.apache.kafka.connect.runtime.distributed.DistributedHerder$13.call(DistributedHerder.java:880)
        at org.apache.kafka.connect.runtime.distributed.DistributedHerder$13.call(DistributedHerder.java:876)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)

Answer 1

connect-distributed只接受一个属性文件，而不是两个。快速入门文件旨在与connect-standalone一起使用

您得到的关于主题名称策略的实际错误很可能是您正在使用的Avro序列化程序版本的问题/错误