Open Rahulkshirsagar88 opened 2 years ago
confluent kafka developer version 6.X
According to your plugin.path
config, you are using 7.0.1 of everything else. Try using the same versions. Especially the Avro converter
I am facing a similar issue any solution?
I am having problem with confluent kafka developer version 6.X
[2022-03-04 12:12:19,269] INFO StandaloneConfig values: access.control.allow.methods = access.control.allow.origin = bootstrap.servers = [localhost:9092] internal.key.converter = class org.apache.kafka.connect.json.JsonConverter internal.value.converter = class org.apache.kafka.connect.json.JsonConverter key.converter = class io.confluent.connect.avro.AvroConverter offset.flush.interval.ms = 60000 offset.flush.timeout.ms = 5000 offset.storage.file.filename = /tmp/connect.offsets plugin.path = [/usr/share/java /opt/striim/Kafka/confluent-7.0.1/share/java, /opt/striim/Kafka/confluent-7.0.1/share/java/confluentinc-kafka-connect-jdbc-10.3.3, /opt/striim/Kafka/confluent-7.0.1/share/java/kafka, /opt/striim/Kafka/confluent-7.0.1/share/java/schema-registry, /opt/striim/Kafka/confluent-7.0.1/share/java/confluent-hub-client, /opt/striim/Kafka/confluent-7.0.1/share/java/schema-registry-plugins, /opt/striim/Kafka/confluent-7.0.1/share/java/confluentinc-kafka-connect-avro-converter-6.1.2/] rest.advertised.host.name = null rest.advertised.port = null rest.host.name = null rest.port = 8083 task.shutdown.graceful.timeout.ms = 5000 value.converter = class io.confluent.connect.avro.AvroConverter (org.apache.kafka.connect.runtime.standalone.StandaloneConfig:223) [2022-03-04 12:12:19,350] INFO Logging initialized @13159ms (org.eclipse.jetty.util.log:186) Exception in thread "main" 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:715) at org.apache.kafka.common.config.ConfigDef$ConfigKey.(ConfigDef.java:944)
at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:137)
at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:157)
at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:196)
at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:358)
at org.apache.kafka.common.config.ConfigDef.define(ConfigDef.java:371)
at io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig.baseConfigDef(AbstractKafkaSchemaSerDeConfig.java:161)
at io.confluent.connect.avro.AvroConverterConfig.(AvroConverterConfig.java:27)
at io.confluent.connect.avro.AvroConverter.configure(AvroConverter.java:65)
at org.apache.kafka.connect.runtime.Worker.(Worker.java:99)