Don’t leave Apache Flink and Schema Registry alone

Schema Registry?

Schema Registry is a central repository with a RESTful interface for developers to define standard schemas and register applications to enable compatibility

source: Confluent

Apache Flink and Schema Registry

Record definition in Avro
docker-compose.yml
Schema registry plugin

A subject refers to the name under which the schema is registered.

Topic _shemas used to store the schemas created
Kafka consumer definition
Kafka producer definition

Bonus: Flink Job reading multiple event types in a single topic

multiple event types in a single topic

Multiple event types deserializer
Flink consumer for multiple event types
Model record
Kafka producer

Summary

--

--

Get the Medium app

A button that says 'Download on the App Store', and if clicked it will lead you to the iOS App store
A button that says 'Get it on, Google Play', and if clicked it will lead you to the Google Play store