Как написать верблюжий роутер с кафкой авро сериализатор в кафку потребителя - PullRequest
Новая
       61

Как написать верблюжий роутер с кафкой авро сериализатор в кафку потребителя

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

Как написать kafka avro сериализатор и десиализатор (т.е. используя io.confluent.kafka.serializers.KafkaAvroDeserializer) 

from("kafka:localhost:9092?topic=customer_payment&groupId=group1&specificAvroReader="+ true+
            "&keyDeserializer=io.confluent.kafka.serializers.KafkaAvroDeserializer&valueDeserializer=io.confluent.kafka.serializers.KafkaAvroDeserializer&schemaRegistryURL=localhost:8081")
    .to("file://C:/Users/Documents/camel-kafka?fileName=MyFile.txt");

Может кто-нибудь помочь, каковы зависимости для kafka avro confluent serializer

Пожалуйста, спросите, нужна ли вам какая-либо информация

Заранее спасибо

1 Ответ

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

Если вы используете Maven. Добавить хранилище слияния: 

<repositories>
<!-- confluent maven repo, required to find avro deps -->
<repository>
  <id>confluent</id>
  <url>https://packages.confluent.io/maven/</url>
</repository>

Добавить зависимости, включая потоки serde, если это так: 

<dependencies>
<!-- avro -->
<dependency>
  <groupId>org.apache.avro</groupId>
  <artifactId>avro</artifactId>
  <version>${avro.version}</version>
</dependency>
<dependency>
  <groupId>io.confluent</groupId>
  <artifactId>kafka-avro-serializer</artifactId>
  <version>${confluent.version}</version>
</dependency>

... Создайте плагин, если вы пытаетесь генерировать Java-типы из схемы Avro. 

<build>
    <plugins>
        <!-- avro -->
        <plugin>
            <groupId>org.apache.avro</groupId>
            <artifactId>avro-maven-plugin</artifactId>
            <version>${avro.version}</version>
            <executions>
                <execution>
                    <phase>generate-sources</phase>
                    <goals>
                        <goal>schema</goal>
                    </goals>
                </execution>
            </executions>
        </plugin>
    </plugins>
</build>
...