Skip to content

Instantly share code, notes, and snippets.

@gaetancollaud
Last active February 13, 2024 21:36
Show Gist options
  • Save gaetancollaud/c018be9c80d902939e8d6975af968e11 to your computer and use it in GitHub Desktop.
Save gaetancollaud/c018be9c80d902939e8d6975af968e11 to your computer and use it in GitHub Desktop.
Quarkus Kafka Protobuf configuration using Confluent schema registry
kafka:
bootstrap:
servers: localhost:9092
schema:
registry:
url: http://localhost:8081
mp:
messaging:
incoming:
logistics:
group:
id: my-group-id
connector: smallrye-kafka
topic: my-topic
value:
deserializer: io.confluent.kafka.serializers.protobuf.KafkaProtobufDeserializer
auto:
offset:
reset: earliest
schema:
registry:
url: ${schema.registry.url}
specific:
protobuf:
value:
type: net.collaud.gaetan.MyClass
<dependencies>
<dependency>
<groupId>io.confluent</groupId>
<artifactId>kafka-protobuf-serializer</artifactId>
<version>${confluent.version}</version>
<exclusions>
<exclusion>
<groupId>jakarta.ws.rs</groupId>
<artifactId>jakarta.ws.rs-api</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>io.confluent</groupId>
<artifactId>kafka-schema-serializer</artifactId>
<version>${confluent.version}</version>
</dependency>
</dependencies>
<repositories>
<repository>
<id>confluent</id>
<url>https://packages.confluent.io/maven/</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</repository>
</repositories>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment