---
schema_version: "1"
id: fcbc6a1c8eae16339638465138f20ea778a14533ec96bb98c647905e75cd9599
title: Integrate Confluent Schema Registry with Kafka Connector - Example
collection: mulesoft
version: current
locale: en-us
portal_url: https://docs.salesforce.com/mulesoft/current/en-us/kafka-connector/4.11/kafka-connector-configure-confluent-example.md
canonical_url: https://docs.mulesoft.com/kafka-connector/4.11/kafka-connector-configure-confluent-example
source_site: docs.mulesoft.com
content_type: documentation
content_hash: 665f76b69dbce5efedc1c211868f2845b912f649e7f2b1a7e9d9e1d5e03d35db
description: MuleSoft Documentation Site
release: "4.11"
latest: false
---
---
product: Apache Kafka Connector
version: 4.11
---

# Integrate Confluent Schema Registry with Kafka Connector - Example

> For the full documentation index, see: https://docs.mulesoft.com/llms.txt

The following example shows how to configure the Confluent Schema Registry using Kafka Connector.

Imagine you are developing a Mule 4 app that processes streaming data from various sources. To
ensure the data conforms to defined schemas and to manage schema evolution effectively, you
integrate Confluent Schema Registry with your Kafka Connector. This setup is crucial for developers
who need to enforce data integrity and compatibility across different versions of data producers and
consumers.

The configuration consists of two parts:

- Configuring the Confluent Schema Registry in the Kafka Connector connection using the **Additional
  Properties** field for the **Consumer** operation.

- Configuring the Kafka Avro dependency in the POM file of the Mule app

## Configure the Confluent Schema Registry in the Kafka Connector Connection

Use the **Additional Properties** field to configure the Confluent Schema Registry.

### Configure the Consumer Operation

To configure the **Consumer** operation in Anypoint Studio:

1.  Open your Mule project in Anypoint Studio and navigate to the **Global Elements** tab.

2.  Click **Create**.

3.  In the search box, type `kafka`.

4.  Select **Apache Kafka Consumer configuration**.

5.  Click **OK**.

6.  In the configuration screen under connection, select **Advanced**.

7.  Fill in all the required connection parameters.

8.  For **Additional properties**, select **Edit inline**.

9.  Click the plus sign to add a new additional property.

10. Set **Key** to `key.deserializer` and **Value** to
    `io.confluent.kafka.serializers.KafkaAvroDeserializer`.

11. Repeat step 9 to add all the required Confluent Schema Registry properties.

In the **Configuration XML** window, check the complete confluent schema registry configuration
under the `<kafka:additional-property>` tags:

```xml
<kafka:consumer-config name="Apache_Kafka_Consumer_configuration” >
<kafka:consumer-plaintext-connection groupId="JenkinsTest">
<kafka:bootstrap-servers >
	<kafka:bootstrap-server value="localhost:9092" />
	</kafka:bootstrap-servers>
<kafka:additional-properties >
  <kafka:additional-property key="key.deserializer" value="’io.confluent.kafka.serializers.KafkaAvroDeserializer” />
    <kafka:additional-property key="value.deserializer value="io.confluent.kafka.serializers.KafkaAvroDeserializer" />
       <kafka:additional-property key="schema.registry.url" value="https://example.us-east-2.aws.confluent.cloud" />
      <kafka:additional-property key="basic.auth.credentials.source" value="USER_INFO" />
      <kafka:additional-property key="basic.auth.user.info" value="<put your credentials here>" />
       <kafka:additional-property key="auto.register.schemas" value="false" />
     <kafka:additional-property key="value.subject.name.strategy" value="io.confluent.kafka.serializers.subject.TopicNameStrategy" />
        </kafka:additional-properties>
        <kafka:topic-patterns >
		<kafka:topic-pattern value="InfraTopic" />
	    </kafka:topic-patterns>
        </kafka:consumer-plaintext-connection>
	    </kafka:consumer-config>
```

## Configure the Kafka Avro dependency in the POM File

In the POM file of the Mule app, configure the Kafka Avro dependency that contains the class to use
to serialize and deserialize. You must update the `<dependencies>`, `<plugin>`, and `<repository>`
sections of the POM file.

### Configure the <dependencies> Section

In the `<dependencies>` section, set `kafka-avro-serializer`:

```xml
<dependencies>
        <dependency>
            <groupId>io.confluent</groupId>
            <artifactId>kafka-avro-serializer</artifactId>
            <version>7.4.0</version>
        </dependency>
</dependencies>
```

### Configure the <plugin> Section

In the `<plugin>` section, set `kafka-avro-serializer` as a `<sharedLibrary>`:

```xml
<plugin>
	<groupId>org.mule.tools.maven</groupId>
	<artifactId>mule-maven-plugin</artifactId>
	<version>${mule.maven.plugin.version}</version>
		<extensions>true</extensions>
				<configuration>
					<additionalPluginDependencies>
						<plugin>
							<groupId>com.mulesoft.connectors</groupId>
							<artifactId>mule-kafka-connector</artifactId>
							<additionalDependencies>
								<dependency>
									<groupId>io.confluent</groupId>
									<artifactId>kafka-avro-serializer</artifactId>
									<version>7.6.1</version>
								</dependency>
							</additionalDependencies>
						</plugin>
					</additionalPluginDependencies>
					<sharedLibraries>
						<sharedLibrary>
							<groupId>io.confluent</groupId>
							<artifactId>kafka-avro-serializer</artifactId>
						</sharedLibrary>
					</sharedLibraries>
					<classifier>mule-application</classifier>
   </configuration>
</plugin>
```

Then, set the `avro-maven-plugin` plugin. This dependency from the `org.apache.avro` group is a
plugin for Apache Maven that facilitates handling Avro schema files in Java projects. The plugin
automatically generates Java classes from Avro schemas (.avsc), protocols (.avpr), and IDL files
(.avdl). This process simplifies development by eliminating the need to manually write Java classes
that represent Avro schemas, ensuring that the Java code is always synchronized with the Avro
schemas.

The `<sourceDirectory>` specifices the folder where the Avro schemas live, for example
`<sourceDirectory>${project.basedir}/PATH_TO_SCHEMAS</sourceDirectory>`.

```xml
<plugin>
<groupId>org.apache.avro</groupId>
	<artifactId>avro-maven-plugin</artifactId>
	<version>1.10.2</version>
	<executions>
		<execution>
			<phase>generate-sources</phase>
			<goals>
				<goal>schema</goal>
			</goals>
			<configuration>
            <sourceDirectory>${project.basedir}/PATH_TO_SCHEMAS</sourceDirectory>
			</configuration>
		</execution>
	</executions>
</plugin>
```

### Configure the <repository> Section

In the `<repository>` section, configure the repository of the dependency:

```xml
<repository>
            <id>confluent</id>
            <url>https://packages.confluent.io/maven/</url>
 </repository>
```

## See Also

- [Kafka Connector Examples](https://docs.mulesoft.com/kafka-connector/4.11/kafka-connector-examples)

- [Salesforce Help](https://help.salesforce.com)