Cluster Linking の構成オプション

Looking for Confluent Cloud Cluster Linking docs? You are currently viewing Confluent Platform documentation. If you are looking for Confluent Cloud docs, check out Cluster Linking on Confluent Cloud.

重要

この機能はプレビュー機能として利用できます。プレビュー機能とは、開発者から早い段階でフィードバックを受けるために提供している Confluent Platform のコンポーネントのことです。この機能は、評価用、本稼働環境以外でのテスト用、あるいは Confluent にフィードバックを提供するために使用できます。

Cluster Linking の有効化

Cluster Linking を有効にするには、以下の行を送信先クラスターのブローカー構成($CONFLUENT_HOME/etc/server.properties など)に追加します。

confluent.cluster.link.enable=true

Cluster Linking を動的構成として使用することはできません。ブローカーを起動する前にこれを有効にしておく必要があります。または、実行中のクラスターで有効にする場合は、ブローカーに構成 confluent.cluster.link.enable=true を設定し、ブローカーを再起動してローリングアップデートを実行します。

クラスターリンク自体の構成オプションは、 kafka-cluster-links コマンド のフラグの値として使用できます。これらについては、以下で説明します。

Cluster Linking と Confluent for Kubernetes の使用

Cluster Linking を、Kubernetes 用の Confluent でデプロイされた Confluent Platform とともに使用できます。

Confluent for Kubernetes で Cluster Linking を構成するには、Kafka カスタムリソースの configOverrides を使用します。configOverrides の使用の詳細については、Confluent for Kubernetes ドキュメントの 構成のオーバーライド を参照してください。

apiVersion: platform.confluent.io/v1beta1
kind: Kafka
metadata:
  name: kafka
  namespace: confluent
spec:
  replicas: 3
  image:
    application: confluentinc/cp-server-operator:6.1.0.0
    init: confluentinc/cp-init-container-operator:6.1.0.0
  dataVolumeCapacity: 10Gi
  configOverrides:
    server:
      - confluent.cluster.link.enable=true # Enable Cluster Linking

Cluster Linking と Ansible の使用

Cluster Linking を、Ansible でデプロイされた Confluent Platform とともに使用できます。

Ansible で Cluster Linking を構成するには、「Ansible との Confluent Platform の構成」の説明に従ってインベントリに kafka_broker_custom_properties セクションを追加します。

以下に例を示します。

all:
  vars:
    kafka_broker_custom_properties:
      confluent.cluster.link.enable: "true"

共通構成オプション

以下の共通プロパティは Cluster Linking に固有のものではありませんが、クラスターリンクのセットアップと管理に特に関係があります。これらは Confluent Platform のクライアント、ブローカー、およびセキュリティ構成に共通するプロパティです。これらについては、示されている各リンク先のセクションで詳しく説明します。

クライアントの構成

AdminClient 全構成のリストについては、「AdminClient の構成」を参照してください。

  • bootstrap.servers
  • client.dns.lookup
  • metadata.max.age.ms
  • retry.backoff.ms
  • request.timeout.ms

クライアント SASL および SSL の構成

  • sasl.client.callback.handler.class
  • sasl.jaas.config
  • sasl.kerberos.kinit.cmd
  • sasl.kerberos.min.time.before.relogin
  • sasl.kerberos.service.name
  • sasl.kerberos.ticket.renew.jitter
  • sasl.kerberos.ticket.renew.window.factor
  • sasl.login.callback.handler.class
  • sasl.login.class
  • sasl.login.refresh.buffer.seconds
  • sasl.login.refresh.min.period.seconds
  • sasl.login.refresh.window.factor
  • sasl.login.refresh.window.jitter
  • sasl.mechanism
  • security.protocol
  • ssl.cipher.suites
  • ssl.enabled.protocols
  • ssl.endpoint.identification.algorithm
  • ssl.engine.factory.class
  • ssl.key.password
  • ssl.keymanager.algorithm
  • ssl.keystore.location
  • ssl.keystore.password
  • ssl.keystore.type
  • ssl.protocol
  • ssl.provider
  • ssl.secure.random.implementation
  • ssl.trustmanager.algorithm
  • ssl.truststore.location
  • ssl.truststore.password
  • ssl.truststore.type