---
schema_version: "1"
id: b8f9b0d3e7537fbca1b5f20cafb288b2c097597b1ebb82abe69e6b37f77a4a1f
title: Apache Kafka Connector 4.9 - 追加設定情報
collection: mulesoft
version: current
locale: ja-jp
portal_url: https://docs.salesforce.com/mulesoft/current/ja-jp/kafka-connector/4.9/kafka-connector-config-topics.md
canonical_url: https://docs.mulesoft.com/jp/kafka-connector/4.9/kafka-connector-config-topics
source_site: docs.mulesoft.com
content_type: documentation
content_hash: f1057284ddf3e86d4e7738726b51160a1de041ea03b4bd7e53c6924968e68b8e
description: MuleSoft Documentation Site
release: "4.9"
latest: false
---
# Apache Kafka Connector 4.9 - 追加設定情報

Apache Kafka 用 Anypoint Connector (Apache Kafka Connector) の追加設定を定義します。

## [](#カスタムパーティショナーを設定する)カスタムパーティショナーを設定する

Mule アプリケーションで Apache Kafka Connector のカスタムパーティショナーを設定できます。

1. Maven を使用して Java プロジェクトを作成し、それにカスタムパーティショナーを追加します。
    
    ```java
    public class CustomPartitioner implements Partitioner {
    // Implementation
    }
    ```
2. Mule アプリケーションに次の連動関係を追加します。
    
    ```java
    <dependencies>
     <dependency>
       <groupId>org.example</groupId>
       <artifactId>custom-partitioner</artifactId>
       <version>1.0-SNAPSHOT</version>
     </dependency>
    </dependencies>
    ```
3. この連動関係を ​`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. カスタムパーティショナーをプロデューサー設定に追加します。
    
    ```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>
    ```

## [](#次のステップ)次のステップ

コネクタの設定が完了したら、​[例](https://docs.mulesoft.com/jp/kafka-connector/4.9/kafka-connector-examples)​を試すことができます。

## [](#関連情報)関連情報

- [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors)
- [MuleSoft ヘルプセンター](https://help.mulesoft.com)