This is a Java application written to illustrate the blog posts:
- You need two schemas to deserialize an Avro message… but which two? (dalelane.co.uk)
- You need two schemas to deserialize an Avro message… but which two? (community.ibm.com)
It produces messages to Kafka topics, serialized as binary-encoded Avro using a variety of Avro schemas.
It then consumes them, using different schemas to illustrate what happens if you don't use schemas correctly.
./0-compile.sh
Create a file called app.properties
and add the config for your Kafka cluster to it.
./1-produce.sh
./2-consume.sh