Integrating Flink Kafka with schema registry

Question

We are using a confluent Platform for Kafka deployment. We are using a schema registry for storing schema. Is it possible to integrate schema registry with flink? How to read the data in AVRO format from confluent platform?

Answer 1

These classes are designed to meet this need

• ConfluentRegistryAvroSerializationSchema
• ConfluentRegistryAvroDeserializationSchema

See the linked JavaDoc for more info on the classes.

Each can be provided to the Kafka Connector via the respective serialization method arguments.

Flink SQL can also be used.