Skip to main content
Quick navigation

RedHat Apicurio Schema Registry

info

This method is temporary as we plan to integrate with the Apicurio Serdes directly in Conduktor soon.

In order to successfully consume messages serialized with RedHat Apicurio Schema Registry, you first need to repackage the Apicurio deserializers into a single jar with all its dependencies. Here we'll use Coursier but feel free to use maven plugins if you prefer.

cs bootstrap io.apicurio:apicurio-registry-serdes-avro-serde:2.2.3.Final -M io.apicurio.registry.serde.avro.AvroKafkaDeserializer --assembly -o apicurio-registry-serdes-avro-serde-2.2.3.Final-with-dependancies.jar

We have also generated the fat jar for your convenience: apicurio-registry-serdes-avro-serde-2.2.3.Final-with-dependancies.jar

Now import this jar file in your cluster configuration and use the class AvroKafkaDeserializer in the Custom Format (Plugin) from the Consume screen.

# Minimum required config with RedHat Registry
apicurio.registry.url=https://test.serviceregistry.rhcloud.com/t/d4d411af-xxxx-4184-xxxx-342e6cd03580/apis/registry/v2
apicurio.auth.username=srvc-acct-a95c41e8-xxxx-4e99-xxxx-217755ad7046
apicurio.auth.password=7d94b05a-xxxx-4f70-xxxx-1e6aba25a8b4