ApacheKafka在Java中使用合流avro序列化程序NoSuchFieldError:PASSWORD

Question

我在java中使用confluent avro producer，但在运行它的时候，它遇到了以下问题。我已经添加了所有需要的罐子。不知道我错过了什么

Exception in thread "main" java.lang.NoSuchFieldError: PASSWORD
    at io.confluent.kafka.serializers.AbstractKafkaAvroSerDeConfig.baseConfigDef(AbstractKafkaAvroSerDeConfig.java:92)
    at io.confluent.kafka.serializers.KafkaAvroSerializerConfig.<clinit>(KafkaAvroSerializerConfig.java:28)
    at io.confluent.kafka.serializers.KafkaAvroSerializer.configure(KafkaAvroSerializer.java:48)
    at org.apache.kafka.common.serialization.ExtendedSerializer$Wrapper.configure(ExtendedSerializer.java:60)
    at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:341)
    at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:302)

我尝试过以下配置

Properties prop = new Properties();
        prop.put("bootstrap.servers", "localhost:9092");
        prop.put("schema.registry.url", "http://localhost:8081");
        //prop.put("basic.auth.user.info", "");
        prop.put("ssl.keystore.type",null);
        prop.put("acks", "all");
        prop.put("retries", "0");
        prop.put("key.serializer", "io.confluent.kafka.serializers.KafkaAvroSerializer");
        prop.put("value.serializer", "io.confluent.kafka.serializers.KafkaAvroSerializer");
        prop.put("group.id", "test");

These are the dependency which i used it.All the jars with latest version.

        <dependency>
            <groupId>io.confluent</groupId>
            <artifactId>kafka-schema-registry</artifactId>
            <version>4.1.0</version>
        </dependency>
        <!-- https://mvnrepository.com/artifact/io.confluent/common-config -->
        <dependency>
            <groupId>io.confluent</groupId>
            <artifactId>common-config</artifactId>
            <version>3.3.1</version>
        </dependency>
        <!-- https://mvnrepository.com/artifact/io.confluent/common-utils -->
        <dependency>
            <groupId>io.confluent</groupId>
            <artifactId>common-utils</artifactId>
            <version>3.3.1</version>
        </dependency>
        <!-- https://mvnrepository.com/artifact/io.confluent/kafka-connect-avro-converter -->
        <dependency>
            <groupId>io.confluent</groupId>
            <artifactId>kafka-connect-avro-converter</artifactId>
            <version>5.2.1</version>
        </dependency>
        <!-- https://mvnrepository.com/artifact/io.confluent/kafka-schema-registry-client -->
        <dependency>
            <groupId>io.confluent</groupId>
            <artifactId>kafka-schema-registry-client</artifactId>
            <version>5.2.1</version>
        </dependency>
        <!-- https://mvnrepository.com/artifact/io.confluent.kafka/connect-utils -->
        <dependency>
            <groupId>io.confluent.kafka</groupId>
            <artifactId>connect-utils</artifactId>
            <version>0.1.18</version>
        </dependency>

        <dependency>
            <groupId>io.confluent.kafka</groupId>
            <artifactId>connect-checkstyle</artifactId>
            <version>0.1.18</version>
        </dependency>
        <!-- https://mvnrepository.com/artifact/io.confluent/rest-utils -->
        <dependency>
            <groupId>io.confluent</groupId>
            <artifactId>rest-utils</artifactId>
            <version>4.1.0</version>
        </dependency>

Answer 1

我在混合版本时看到过这个错误

您应该只需要它，因为公共util、客户机、rest util等都是可传递的依赖项

    <dependency>
        <groupId>io.confluent</groupId>
        <artifactId>kafka-avro-serializer</artifactId>
        <version>5.2.1</version>
    </dependency>

https://docs.confluent.io/current/app-development/index.html#native-clients-with-serializers

删除其余的依赖项，或者至少为版本创建一个属性并重新使用它