---
schema_version: "1"
id: 27eea28c8360ae8002bb84c0ad5d8380d40633ce7178adbb661711269430d38e
title: Apache Kafka Connector 4.14 - Additional Configuration Information
collection: mulesoft
version: current
locale: en-us
portal_url: https://docs.salesforce.com/mulesoft/current/en-us/kafka-connector/4.14/kafka-connector-config-topics.md
canonical_url: https://docs.mulesoft.com/kafka-connector/4.14/kafka-connector-config-topics
source_site: docs.mulesoft.com
content_type: documentation
content_hash: a0ed5d7d09caef51bf299a2a90c29ea7f6b72ab9911edaf90a1c5fb4cce18d1b
description: MuleSoft Documentation Site
release: "4.14"
latest: false
---
---
product: Apache Kafka Connector
version: 4.14
---

# Apache Kafka Connector 4.14 - Additional Configuration Information

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

Set additional configuration for Anypoint Connector for Apache Kafka (Apache Kafka Connector).

## Configure a Custom Partitioner

You can configure a custom partitioner for Apache Kafka Connector in a Mule app:

1.  Use Maven to create a Java project and add the custom partitioner to it:

    ```java
    public class CustomPartitioner implements Partitioner {
    // Implementation
    }
    ```

2.  Add this dependency in the Mule app:

    ```java
    <dependencies>
     <dependency>
       <groupId>org.example</groupId>
       <artifactId>custom-partitioner</artifactId>
       <version>1.0-SNAPSHOT</version>
     </dependency>
    </dependencies>
    ```

3.  Add this dependency to `additionalPluginDependencies`:

    ```java
    <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>
         <dependency>
          <groupId>org.example</groupId>
          <artifactId>custom-partitioner</artifactId>
          <version>1.0-SNAPSHOT</version>
         </dependency>
        </additionalDependencies>
       </plugin>
       </additionalPluginDependencies>
       <classifier>mule-application</classifier>
     </configuration>
    </plugin>
    ```

4.  Add the custom partitioner to the producer configuration:

    ```java
    <kafka:producer-config name="Apache_Kafka_Producer_configuration"
        doc:name="Apache Kafka Producer configuration"
        doc:id="cb9de3c5-d6d2-4f9b-a255-75a9985bffb7">
        <kafka:producer-plaintext-connection>
            <kafka:bootstrap-servers>
                <kafka:bootstrap-server value="<kafka-url>" />
            </kafka:bootstrap-servers>
            <kafka:additional-properties>
                <kafka:additional-property key="key.serializer"
                    value="org.apache.kafka.common.serialization.StringSerializer" />
                <kafka:additional-property key="value.serializer"
                    value="com.mulesoft.connectors.kafka.internal.model.serializer.MuleKafkaAvroSerializer" />
                <kafka:additional-property key="schema.registry.url"
                    value="<schema-registry-url>" />
                <kafka:additional-property key="basic.auth.credentials.source"
                    value="USER_INFO" />
                <kafka:additional-property key="basic.auth.user.info"
                    value="user:pass" />
                <kafka:additional-property key="auto.register.schemas"
                    value="true" />
                <kafka:additional-property key="value.subject.name.strategy"
                    value="io.confluent.kafka.serializers.subject.TopicNameStrategy" />
                <kafka:additional-property key="partitioner.class"
                    value="org.example.CustomPartitioner" />
            </kafka:additional-properties>
        </kafka:producer-plaintext-connection>
    </kafka:producer-config>
    ```

## Next Step

After you complete configuring the connector, you can try the [examples](https://docs.mulesoft.com/kafka-connector/4.14/kafka-connector-examples).

## See Also

- [Introduction to Anypoint Connectors](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors)

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