Класс не найден - Авро с верблюдом - PullRequest
Новая
       16

Класс не найден - Авро с верблюдом

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

Я использую авро схему из: https://avro.apache.org/docs/current/gettingstartedjava.html#Defining+a+schema Я использовал avro-tools-1.8.1.jar для создания класса User из схемы. Схема находится в src / main / resources / avro, а сгенерированный пользователем класс - в src / main / java / avro. У меня есть простой маршрут 

(and I tried to load the schema from dir as well)

AvroDataFormat format = new AvroDataFormat(User.getClassSchema());
from("topic1")
 .marshal(format)
 .to("topic2")

Я пытался использовать: 

.marshal().avro().to("topic2")

но не успех.

Я получил "ClassCastException: [B не может быть приведен к org.apache.avro.generic.IndexedRecord"

Я не понимаю, чего мне не хватает, это должно работать с marhsal (). Avro () или marshal (). Avro (схема), я вижу, что схема загружена правильно. Я последовал этому примеру: https://github.com/apache/camel/blob/master/components/camel-avro/src/test/java/org/apache/camel/dataformat/avro/AvroGenericMarshaAndUnmarshaTest.java

...