--- schema_version: "1" id: 491326e295a24510bda34b6e557f901d6301892a1880d44f018682e9d3504824 title: Confluent Schema Registry 1.1 Examples collection: mulesoft version: current locale: en-us portal_url: https://docs.salesforce.com/mulesoft/current/en-us/confluent-schema-registry-connector/1.1/confluent-schema-registry-connector-examples.md canonical_url: https://docs.mulesoft.com/confluent-schema-registry-connector/1.1/confluent-schema-registry-connector-examples source_site: docs.mulesoft.com content_type: documentation content_hash: 423b891631d7a8f311ad45f68ac601253d7a063ab100284a3d38711cd3df2fc1 description: MuleSoft Documentation Site release: "1.1" latest: false --- --- product: Confluent Schema Registry Connector version: 1.1 --- # Confluent Schema Registry 1.1 Examples > For the full documentation index, see: https://docs.mulesoft.com/llms.txt This example shows how to publish and consume avro messages by integrating Confluent Schema Registry with Kafka Connector to reduce the size of the messages. The example contains two flows: 1. The first flow generates an avro message containing the schema and sends it to the Kafka topic. The **Transform Message** component creates an avro message with the schema and the **Replace AVRO schema with id** operation replaces the schema embedded in the message with an ID from Confluent Schema Registry. 2. The second flow reads the avro message from the Kafka topic and prints out the content of the deserialized avro message to the console. The **Replace id with AVRO schema** operation replaces the ID in the received message with the actual schema retrieved from Confluent Schema Registry. ## Create the Producer Flow The Producer flow publishes a message to the configured Kafka topic. The following screenshot shows the Producer flow in Anypoint Studio: ![Confluent Schema Registry Connector Producer Flow in Studio](/mulesoft/current/en-us/confluent-schema-registry-connector/1.1/_images/confluent-schema-registry-producer-flow.png) In this flow, you configure: - An HTTP **Listener** component - **Transform Message** component - **Logger** component - **Replace AVRO schema with id** operation - **Publish** operation - A second **Transform Message** component ### Configure HTTP Listener Configure **HTTP Listener** to initiate a Mule flow when a call is made to the `/` account path on `localhost`, port `8082`. This example uses variables for some field values. You can either: - Replace the variables with their values in the code. - Provide the values for each variable in a properties file and then refer to that file from the connector configuration. If you don’t know how to use a properties file, see [Configuring Property Placeholders](https://docs.mulesoft.com/mule-runtime/latest/mule-app-properties-to-configure). To configure **HTTP Listener**: 1. Create a new Mule project in Studio. 2. In **Mule Palette**, search for `http` and select the **Listener** operation: 3. Drag the **Listener** operation onto the canvas. 4. In the **Listener** configuration, click the **Add** icon next to the **Connector configuration** field to add a global element. 5. Click **OK** to accept the defaults. 6. Set the **Path** field to `/`: ### Add the First Transform Message Component The first **Transform Message** component generates an avro message containing the schema: 1. In **Mule Palette**, search for `transform message`. 2. Drag the **Transform Message** component onto the canvas, next to the **Listener** component. 3. In the **Transform Message** configuration, overlay the brackets in the **Output** section with this XML: ```xml %dw 2.0 output application/avro schemaUrl='classpath://schema.json' --- { "f1": "demo_message" } ``` The following shows the content of the schema used in this example: `{"type":"record","name":"myrecord","fields":[{"name":"f1","type":"string"}]}` This schema describes a JSON object that has a field named `f1` and has the type `string`. ### Add a Logger Component 1. In **Mule Palette**, search for `logger`. 2. Drag the **Logger** component onto the canvas, next to the **Transform Message** component. 3. Configure the following fields:
FieldValue

Display Name

Name for the logger, such as Log Response

Message

Enter #[payload].

Level

INFO (Default)

### Add the Replace AVRO Schema with ID Operation The **Replace AVRO schema with id** operation replaces the schema in an avro message with an ID from Confluent Schema Registry to reduce the size of the message. 1. Drag the **Replace AVRO schema with id** operation onto the canvas, next to the **Logger** component. 2. In the **Replace AVRO schema with id** configuration, click the **Connector configuration** dropdown and select **Confluent\_Schema\_Registry\_Connector\_Config**. 3. Configure the following fields in the **Replace AVRO schema with id** properties window:
FieldValue

Subject

${config.subject}

Message

payload

### Add the Publish Operation The **Publish** operation publishes a message to the Kafka topic. 1. Drag the **Publish** operation onto the canvas, next to the **Replace AVRO schema with id** operation. 2. Configure the following fields in the **Publish** properties window:
FieldValue

Display Name

Name for the operation, such as Producer

Topic

#[payload.topic]

Key

#[now()]

3. In the **General** configuration screen for the **Publish** operation, click the **Add** icon to access the global element configuration fields. 1. In the **Bootstrap server URLs** field, select **Edit inline** and then click the **Add** icon. 2. Enter the value `${config.basic.bootstrapServers}` and click **Finish**. ### Add the Second Transform Message Component The second **Transform Message** component prints the response of the **Publish** operation. 1. In **Mule Palette**, search for `transform message`. 2. Drag the **Transform Message** component onto the canvas, next to the **Publish** operation. 3. In the **Transform Message** configuration, overlay the brackets in the **Output** section with this XML: ```xml %dw 2.0 output application/json --- payload ``` ## Create the Consumer Flow The Consumer flow consumes the published message from the Kafka topic and prints it out to the console. The following screenshot shows the Consumer flow in Anypoint Studio: ![Confluent Schema Registry Connector Consumer Flow in Studio](/mulesoft/current/en-us/confluent-schema-registry-connector/1.1/_images/confluent-schema-registry-consumer-flow.png) In this flow, you configure: - **Message listener** - **Logger** component - **Replace id with AVRO schema** operation - **Transform Message** component - A second **Logger** component ### Add a Message Listener The **Message listener** consumes the published message from the Kafka topic. 1. Drag the **Message listener** onto the canvas. 2. Configure the following fields in the **Message listener** properties window:
FieldValue

Display Name

Name for the operation, such as Producer

Topic

#[payload.topic]

Key

#[now()]

3. Click the **Add** icon next to the **Connector configuration** field to access the global element configuration fields. 4. Complete these fields: 1. In the **Bootstrap server URLs** field, select **Edit inline** and then click the **Add** icon. 2. Enter the value `${config.basic.bootstrapServers}` and click **Finish.** 3. In the **Group ID** field, enter `${consumer.groupId}`. 4. In the **Topic Subscription Patterns** field, select **Edit inline** and then click the **Add** icon. 5. Enter the value `${config.topics}` and click **Finish**. ### Add the First Logger Component 1. In **Mule Palette**, search for `logger`. 2. Drag the **Logger** component onto the canvas, next to **Message listener**. 3. Configure the following fields:
FieldValue

Display Name

Name for the logger, such as Log Response

Message

Enter #[payload].

Level

INFO (Default)

### Add the Replace ID with AVRO Schema Operation The **Replace id with AVRO schema** operation replaces the embedded ID with the avro schema. 1. Drag the **Replace id with AVRO schema** operation onto the canvas, next to the **Logger** component. 2. In the **Replace id with AVRO schema** configuration, click the **Connector configuration** dropdown and select **Confluent\_Schema\_Registry\_Connector\_Config**. 3. Configure the following fields in the **Replace id with AVRO schema** properties window:
FieldValue

Message

payload

### Add the Transform Message Component The **Transform Message** component transforms the payload into JSON. 1. In **Mule Palette**, search for `transform message`. 2. Drag the **Transform Message** component onto the canvas, next to the **Replace id with AVRO schema** operation. 3. In the **Transform Message** configuration, overlay the brackets in the **Output** section with this XML: ```xml %dw 2.0 output application/json --- payload ``` ### Add the Second Logger Component 1. In **Mule Palette**, search for `logger`. 2. Drag the **Logger** component onto the canvas, next to **Transform Message**. 3. Configure the following fields:
FieldValue

Display Name

Name for the logger, such as Log Response

Message

Enter #[payload[0]].

Level

INFO (Default)

## XML for Publishing and Consuming Avro Messages ```xml ``` ## See Also - [Introduction to Anypoint Connectors](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [Salesforce Help](https://help.salesforce.com)