JarCastingKafka Registryless Avro Serdes
If you want to use Avro in your Kafka project, but aren't using Confluent Schema Registry, you can use this Avro Serdes instead. Note that the record schema will be serialized with each message.
Install
dependencies {
implementation 'com.mitchseymour:kafka-registryless-avro-serdes:0.1.0'
}
Usage
Once you've generated your classes from an Avro schema file, for example, with the gradle-avro-plugin, you can use the AvroSerdes#get method to generate an Avro Serdes for a generated class. For example, if you generated a class named Tweet from the following definition:
{
"namespace": "com.mitchseymour.model",
"name": "Tweet",
"type": "record",
"fields": [
{
"name": "id",
"type": "long"
},
{
"name": "text",
"type": "string"
}
]
}
You could then create an Avro Serde for that class using this code:
Serde<Tweet> serde = AvroSerdes.get(Tweet.class);
The resulting Serde can be used anywhere you would normally use one of Kafka's built-in Serdes. For example, in a Kafka Streams app, you could do this:
stream.to("tweets", Produced.with(Serdes.String(), AvroSerdes.get(Tweet.class)));