Apache Kafka コネクタ構成ガイド

構成

コネクタマーケットプレイスにアクセスして新しいコネクタを追加します。コネクタを追加する一般的な手順については、コネクタについてを参照してください。

コネクタを追加した後、以下の構成を構成します：

• 認証タイプ
  • SASL/PLAIN（デフォルト）：ユーザー名とパスワードを使用して認証します。
  • SASL SCRAM-SHA-512：SCRAM-SHA-512 チャレンジレスポンス認証を使用します。このオプションを選択する前に、Kafka ブローカーが SCRAM-SHA-512 メカニズムをサポートするように構成してください。
• ブートストラップサーバー
  • （必須）エンドポイントの Kafka ブートストラップサーバー。例えば、Conduktor Gateway ホストまたは Kafka ブローカー：gateway.customer-domain.com:6969。
  • エンドポイントは、通常、PrivateLink、VPN、またはネットワークピアリングを通じて Tealium からアクセス可能である必要があります。
• CA証明書（PEM）
  • Kafka ブローカーまたはゲートウェイによって提示される TLS 証明書を検証するために使用される PEM エンコードされた CA 証明書チェーン。
  • エンドポイントが内部 PKI、プライベート CA、または自己署名証明書を使用している場合に必要です。
• ホスト名検証の無効化
  • TLS 証明書とホスト名が一致するかどうかの検証を無効にします。
  • SNI や非標準のホスト名を使用する場合は、この構成を無効にします。デフォルト：検証有効。
• Confluent スキーマレジストリ URL
  • （オプション）スキーマレジストリの URL。例：https://schema-registry.example.com:8081。
  • カスタムアクションでスキーマ検証を使用する場合に必要です。
• Confluent スキーマレジストリ ユーザー名
  • （オプション）HTTP Basic 認証を使用してスキーマレジストリに認証するためのユーザー名。
  • スキーマレジストリが認証を要求する場合に必要です。
• Confluent スキーマレジストリ パスワード
  • （オプション）HTTP Basic 認証を使用してスキーマレジストリに認証するためのパスワードまたは API シークレット。
  • スキーマレジストリが認証を要求する場合に必要です。
• サービスアカウントユーザー名
  • （必須）ブローカーとの認証に使用される Kafka プリンシパル。
  • SASL/PLAIN の場合は SASL ユーザー名を、SASL SCRAM-SHA-512 の場合は SCRAM プリンシパルを入力します。
• サービスアカウントトークン / パスワード
  • （必須）サービスアカウントプリンシパルの認証情報。
  • SASL/PLAIN の場合は JWT トークンまたは同等の認証情報を、SASL SCRAM-SHA-512 の場合は SCRAM パスワードを入力します。
• 圧縮タイプ
  • Kafka に送信されるメッセージの圧縮アルゴリズム。帯域幅と保存コストを削減します。
  • デフォルトは GZIPです。
• 最大メッセージサイズ（バイト）
  • 一回のリクエストで送信される単一メッセージまたはバッチの最大サイズ（バイト単位）。大きな訪問プロファイルを収容するためにこの値を増やしますが、ブローカーの構成と一致することを確認してください。
  • デフォルトは 1,048,576 バイト（1 MB）。最大は 2,097,152 バイト（2 MB）です。
  • この値は Kafka ブローカーの message.max.bytes 構成を超えてはなりません。
• クライアント ID
  • 各リクエストにブローカーに送信される識別子で、ログ記録、モニタリングの帰属、およびクォータの強制に使用されます。
  • デフォルトは次の形式で自動生成された識別子です：tealium-{account}-{profile}-{connectorId}。
  • サポートされる文字は、文字、数字、ピリオド (.)、ハイフン (-)、アンダースコア (_)です。
• 確認（acks）
  • メッセージが正常に書き込まれたと見なされる前に必要なブローカーの確認の数を指定します。
  • 0：確認なし。最も速いが、無音のデータ損失のリスクがあります。
  • 1：パーティションリーダーがローカルに書き込んだ後にメッセージを確認します。配信保証付きで最も速いです。
  • All：すべての同期レプリカが確認する必要があります。50〜100ミリ秒の遅延が追加されますが、データ損失のリスクがなくなります。
• パーティショナー戦略
  • メッセージキーが構成されている場合を除き、パーティションが指定されていない場合にプロデューサーがメッセージをパーティションに割り当てる方法を制御します。
  • デフォルト：最適なスループットのためにスティッキーバッチングを使用します。
  • ラウンドロビン：すべてのパーティションにメッセージを均等に分配します。
• プロデューサー - 再接続バックオフ
  • 接続失敗後にブローカーに再接続する前に待機する時間（ミリ秒単位）。
  • デフォルトは 50 ミリ秒です。
• プロデューサー - リトライ
  • 送信操作が失敗した場合の最大リトライ試行回数。
  • 空白の場合、Kafka クライアントのデフォルトが使用されます。
• プロデューサー - リトライバックオフ
  • 同じレコードのリトライ試行間の待機時間（ミリ秒単位）。
  • デフォルトは 100 ミリ秒です。

アクション

次へ をクリックするか、アクション タブに進んでコネクタアクションを構成します。

次のセクションでは、各アクションのパラメータとオプションの構成方法について説明します。

すべてのイベントデータを送信

パラメータ

すべての訪問データを送信

パラメータ

カスタムイベントデータを送信

パラメータ

カスタム訪問データの送信

パラメータ

ログイベント全体の送信

パラメータ

ログイベントの送信

パラメータ

コネクタログパラメータ

パラメータの説明については、コネクタログパラメータを参照してください。