Поддержка Apache Camel Kafka для реестра Confluent схемы

Question

Я пытаюсь создать верблюжий маршрут с компонентом kafka, пытаясь использовать события с io.confluent.kafka.serializers.KafkaAvroDeserializer и URL-адрес schemaRegistry вместе с другими параметрами компонента. Я не уверен, полностью ли это поддерживается Camel-Kafka в настоящее время. Может кто-нибудь прокомментировать это?

from("kafka:{{kafka.notification.topic}}?brokers={{kafka.notification.brokers}}"
                + "&maxPollRecords={{kafka.notification.maxPollRecords}}"
                + "&seekTo={{kafka.notification.seekTo}}"
                + "&specificAvroReader=" + "true"
                + "&valueDeserializer=" + "io.confluent.kafka.serializers.KafkaAvroDeserializer"
                +"&schemaRegistryURL=localhost:9021"
                + "&allowManualCommit={{kafka.notification.autocommit}})

specificAvroReader & schemaRegistryURL - свойства, которые, похоже, не поддерживаются.

Answer 1

Я полагаю, что в настоящее время верблюд-кафка может работать только с реестром схемы Confluent - это написать собственный AvroSerilizer / AvroDeserializer (io.confluent.kafka.serializers.AbstractKafkaAvroSerializer / io.confluent.kafka.serializers.AvstractDaf).Например:

BlablaDeserializer extends AbstractKafkaAvroDeserializer implements Deserializer<Object>

и

BlablaSerializer extends AbstractKafkaAvroSerializer implements Serializer<Object>

, а затем установите их на компонент верблюда.Например, для значения это будет:

 KafkaConfiguration kafkaConfiguration.setValueDeserializer(...)

Answer 2

Получилось это после добавления компиляции 'org.apache.camel: camel-kafka: 3.0.0-M2', которую можно найти в этом промежуточном репозитории https://repository.apache.org/content/repositories/orgapachecamel-1124/org/apache/camel/

Я думаю, что 3.0.0-M2 будет официально поддерживаться Camel в начале следующей недели.

Редактировать: 3.0.0-M2 доступны сейчас https://repository.apache.org/content/repositories/releases/org/apache/camel/apache-camel/3.0.0-M2/

Имеет поддержку реестра Camel Kafka & Confluent Schema