Skip to content

andrewscul/january

 
 

Repository files navigation

HDInsight Managed Kafka with Confluent Kafka Schema Registry

Kafka Schema Registry provides serializers that plug into Kafka clients that handle message schema storage and retrieval for Kafka messages that are sent in the Avro format. Its used to be a OSS project by Confluent , but is now under the Confluent community license . The Schema Registry can additionally serves the below purposes

  • Store and retrieve schemas for producers and consumers
  • Enforce backward/forward /full compatibility on Topics
  • Decrease the size of the payload sent to Kafka

In an HDInsight Managed Kafka cluster the Schema Registry is typically deployed on an Edge node to allow compute separation from Head Nodes.

Below is a representative architecture of how the Schema Registry is deployed on an HDInsight cluster. Note that Schema Registry natively exposes a REST API for operations on it. Producers and consumers can interact with the Schema Registry from within the VNet or using the Kafka REST Proxy.

HDInsight Kafka Schema Registry

Click Next to start the Lab

Releases

No releases published

Packages

No packages published

Languages

  • Python 84.0%
  • Shell 11.4%
  • PowerShell 4.6%