Using Google Protobuf serializer/deserializer
If you are using Protocol Buffers serializer/deserializer, please note the following configuration properties.
For Confluent Schema Registry
Confluent protobuf library is io.confluent:kafka-protobuf-serializer
.
Note that this library is not available in Maven Central, you need to
use the Confluent Maven
repository.
Consumer
Property | Recommended value |
---|---|
value.deserializer | io.confluent.kafka.serializers.protobuf.KafkaProtobufDeserializer |
schema.registry.url | http://{your_host}:{your_port}/ |
mp.messaging.incoming.[channel].specific.protobuf.value.type | your.package.DomainObjectKey$Key |
mp.messaging.incoming.[channel].specific.protobuf.key.type | your.package.DomainObjectValue$Value |
Example:
1 2 3 4 |
|
Producer
Property | Recommended value |
---|---|
value.serializer | io.confluent.kafka.serializers.protobuf.KafkaProtobufSerializer |
schema.registry.url | http://{your_host}:{your_port}/ |
Example:
1 2 |
|