Schema Registry

Let’s publish messages using the Kafka Schema Registry. We will use KAVROProducer and KAVROConsumer found in KafkaSchema.

This example uses OAuth2 for both producing and consuming messages as well as the Kafka schema registry. It is also possible to use API Keys with schema registry just as we did for producing and consuming in the hello world example. You have been supplied an OAuth2 Key with tenant admin rights in a tenant with your student id (e.g. summitstudent1).

Configuration of KProducer is completed in resources/client.properties.kafkaschema. You will need to make the following changes to client.properties.kafkaschema:

• Edit topic1 to use your student number (e.g. studentsummit1.developer.kafkaschematopic)
• Copy your OAuth2 Key to the resources folder
• Edit oauth.credentials.url to point to your OAuth2 Key using a relative path

Execute KProducer and KConsumer. You should see the following: