Kafka接続のプロパティ

スキーマレジストリのセキュリティ設定プロパティ

Kerberised Kafkaクラスタからのデータの読み取りまたは書き込みのためのkrb5.confファイルの設定

1Kerberised Kafkaクラスタにkrb5.confファイルがあることをを確認してください。
2デフォルトのレルムとKDCを設定します。デフォルトの/etc/krb5.confファイルが設定されていないか、設定を変更する場合は、/etc/krb5.confファイルに次の行を追加します。
[libdefaults]
default_realm = <REALM NAME>
dns_lookup_realm = false
dns_lookup_kdc = false
ticket_lifetime = 24h
renew_lifetime = 7d
forwardable = true

[realms]
<REALM NAME> = {
kdc = <Location where KDC is installed>
admin_server = <Location where KDC is installed>
}
[domain_realm]
.<domain name or hostname> = <KERBEROS DOMAIN NAME>
<domain name or hostname> = <KERBEROS DOMAIN NAME>
3実行時にjava.security.auth.login.configファイルを使用して静的JAAS設定ファイルをJVMに渡すには、次のタスクを実行します。
1. aJAAS設定ファイルがあることを確認してください。
JAAS設定の作成およびKafkaクライアントのキータブの設定については、https://kafka.apache.org/0101/documentation/#securityのApache Kafkaのドキュメントを参照してください。
たとえば、JAAS設定ファイルには、次の設定行を含めることができます。
//Kafka Client Authentication. Used for client to kafka broker connection
KafkaClient {
com.sun.security.auth.module.Krb5LoginModule required
doNotPrompt=true
useKeyTab=true
storeKey=true
keyTab="<path to Kafka keytab file>/<Kafka keytab file name>"
principal="<principal name>"
client=true
};
2. bJAAS設定ファイルとキータブファイルをすべてのSecure Agentの同じ場所に配置します。
ランタイム環境のすべてのSecure Agentがアクセスできる場所にファイルを配置することをお勧めします。たとえば、/etcまたは/tempです。
3. c以下のプロパティを設定します。

Kafka接続

追加接続プロパティをKafka接続で設定し、次の形式で値を指定します。

security.protocol=SASL_PLAINTEXT,sasl.kerberos.service.name=kafka,sasl.mechanism=GSSAPI

ソース

詳細ソースプロパティの［コンシューマ設定プロパティ］を設定して、Kafka接続の［追加接続プロパティ］で指定した値をオーバーライドします。次の形式で値を指定します。

security.protocol=SASL_PLAINTEXT,sasl.kerberos.service.name=kafka,sasl.mechanism=GSSAPI

ターゲット

詳細ターゲットプロパティの［プロデューサ設定プロパティ］を設定して、Kafka接続の［追加接続プロパティ］で指定した値をオーバーライドします。次の形式で値を指定します。

security.protocol=SASL_PLAINTEXT,sasl.kerberos.service.name=kafka,sasl.mechanism=GSSAPI

4JAAS設定をsasl.jaas.config設定プロパティに埋め込むには、次のプロパティを設定します。

Kafka接続

追加接続プロパティをKafka接続で設定し、次の形式で値を指定します。

security.protocol=SASL_PLAINTEXT,sasl.kerberos.service.name=kafka,sasl.mechanism=GSSAPI,
sasl.jaas.config=com.sun.security.auth.module.Krb5LoginModule required useKeyTab=true
storeKey=true doNotPrompt=true serviceName="<service_name>" keyTab="<location of keytab file>"
client=true principal="<principal_name>";

ソース

詳細ソースプロパティの［コンシューマ設定プロパティ］を設定して、Kafka接続の［Kerberos接続プロパティ］で指定した値をオーバーライドします。次の形式で値を指定します。

security.protocol=SASL_PLAINTEXT,sasl.kerberos.service.name=kafka,sasl.mechanism=GSSAPI,
sasl.jaas.config=com.sun.security.auth.module.Krb5LoginModule required useKeyTab=true
storeKey=true doNotPrompt=true serviceName="<service_name>" keyTab="<location of keytab file>"
client=true principal="<principal_name>";

ターゲット

詳細ターゲットプロパティの［プロデューサ設定プロパティ］を設定して、Kafka接続の［Kerberos接続プロパティ］で指定した値をオーバーライドします。次の形式で値を指定します。

security.protocol=SASL_PLAINTEXT,sasl.kerberos.service.name=kafka,sasl.mechanism=GSSAPI,
sasl.jaas.config=com.sun.security.auth.module.Krb5LoginModule required useKeyTab=true
storeKey=true doNotPrompt=true serviceName="<service_name>" keyTab="<location of keytab file>"
client=true principal="<principal_name>";

KafkaクラスタのSASL PLAIN認証の設定

Kafka接続

［追加接続プロパティ］プロパティをKafka接続で設定し、次の形式で値を指定します。

security.protocol=SASL_SSL,sasl.mechanism=PLAIN,sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="<username>" password="<password>";

［セキュリティ設定セクション］で、［一方向］をSSLモードとして指定し、SSLトラストストアファイルパスとSSLトラストストアパスワードを指定します。

ソース

詳細ソースプロパティの［コンシューマ設定プロパティ］プロパティを設定して、Kafka接続の［追加接続プロパティ］プロパティで指定した値をオーバーライドします。次の形式で値を指定します。

security.protocol=SASL_SSL,sasl.mechanism=PLAIN,sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="<username>" password="<password>";

ターゲット

詳細ターゲットプロパティの［プロデューサ設定プロパティ］プロパティを設定して、Kafka接続の［追加接続プロパティ］プロパティで指定した値をオーバーライドします。次の形式で値を指定します。

security.protocol=SASL_SSL,sasl.mechanism=PLAIN,sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="<username>" password="<password>";

Azure Event Hub KafkaブローカーのSASL PLAIN認証の設定

Cloud Confluent KafkaクラスタのSASL_SSL認証の設定

Amazon Managed Streaming for Apache Kafkaへの接続