Использование сливного сериализатора avro в Java - NoSuchFieldError: ПАРОЛЬ - PullRequest
0 голосов
/ 26 июня 2019

Я использую confluent avro продюсер в java, но пока я запускаю его, выполняя ниже проблему. Я добавил все необходимые баночки. Не имею понятия, что я пропустил?

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");

Это зависимость, которую я использовал. Все банки с последней версией.

        <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>

1 Ответ

0 голосов
/ 26 июня 2019

Я видел эту ошибку при смешивании версий.Это также не последние версии, потому что MvnReposistory не кэширует реальное Confluent репо.

Вам нужно только это

    <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

Удалите остальные зависимости

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...