Kafka java.lang.ClassNotFoundException: io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe ⇐ JAVA

[Anonymous]

Проблема с Kafka, ошибка

05 января 2023 г. 11:19:47.532 СЕРЬЕЗНАЯ [http-nio-8080-exec-32] org .apache.catalina.core.StandardWrapperValve.invoke Servlet.service() для сервлета [jpublish] в контексте с путем [/DS] выдал исключение [выполнение сервлета выдало исключение] с основной причиной java.lang.ClassNotFoundException:
io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

Код: Выделить всё

Properties props = new Properties();
props.put("bootstrap.servers", url);
props.put("linger.ms", 1);
props.put("max.block.ms", 10000);
props.put("group.id", "group");
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, IntegerSerializer.class.getName());
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, KafkaJsonSchemaSerializer.class.getName());
props.put(KafkaJsonSchemaSerializerConfig.SCHEMA_REGISTRY_URL_CONFIG, "http://localhost:8081");

Producer producer = new KafkaProducer(props);
ProducerRecord record = new ProducerRecord(topic, uuid, message);

producer.send(record);

producer.close();

lib kafka в проекте


class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe я могу импортировать и без ошибок


есть предложения?
уже пробовали включить kafka- serde-tools по ссылке, но не работает

Подробнее здесь: https://stackoverflow.com/questions/750 ... -abstractk