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

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

BlablaDeserializer extends AbstractKafkaAvroDeserializer implements Deserializer<Object>

и

BlablaSerializer extends AbstractKafkaAvroSerializer implements Serializer<Object>

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

 KafkaConfiguration kafkaConfiguration.setValueDeserializer(...)

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

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

Имеет поддержку Camel Kafka & amp; Реестр схемы слияния