Confluent Kafka Connect コネクタ構成ガイド

API 情報

このコネクタは以下のベンダー API を使用します：

• API 名：Confluent REST Proxy for Kafka
• API バージョン：v3
• API エンドポイント：https://github.com/confluentinc/kafka-rest

構成

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

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

• API キー：（必須）あなたの Confluent Cloud API キー。
• API シークレット：（必須）あなたの Confluent Cloud API シークレット。
• ブートストラップサーバー：（必須）プロトコルやポートを除いた Confluent Cloud Kafka REST エンドポイントのホスト名。例えば、エンドポイントが https://pkc-12345.us-west4.gcp.confluent.cloud:443 の場合、pkc-12345.us-west4.gcp.confluent.cloud を入力します。
• クラスター ID：（必須）あなたの Confluent Cloud クラスター ID（例：lkc-12345）。

これらの構成に関する詳細情報は以下を参照してください：

• Confluent Cloud: Confluent Cloud に認証するための API キーの使用
• Confluent Cloud クラスター: Cloud Console でクラスターの詳細をどのように表示しますか？

アクション

アクション名	AudienceStream	EventStream
すべてのイベントデータを送信	✗	✓
カスタムイベントデータを送信	✗	✓
すべての訪問データを送信	✓	✗
カスタム訪問データを送信	✓	✗
ログイベントを送信	✗	✓
すべてのログイベントを送信	✗	✓

アクションの名前を入力し、アクションタイプを選択します。

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

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

バッチ制限

このコネクタは、ベンダーへの大量データ転送をサポートするためにバッチリクエストを使用します。並列処理により、イベントがベンダーに順不同で到達する可能性があります。順序が重要な場合は、イベントにシーケンス値を追加してください。詳細については、バッチアクションを参照してください。次のいずれかの閾値に達するか、プロファイルが公開されるまでリクエストはキューに入れられます：

• 最大リクエスト数：100
• 最古のリクエストからの最大時間：60分
• リクエストの最大サイズ：10 MB

パラメータ

パラメータ	説明
トピック ID	トピックを選択するか、トピック ID を入力します。
パーティション ID	パーティション ID を選択します。
データ形式	データ配信の形式を指定します。可能な値：JSON, STRING, BINARY。
ヘッダー	オプションのパラメータ。ヘッダーのプロパティと値をリストするキーと値のペアのセット。
メッセージキー	生のメッセージキーを指定します。データ形式として BINARY を選択した場合、Tealium はこの値をエンコードして送信します。
タイムスタンプ	ISO 8601 UTC 形式のトピックタイムスタンプ。例：YYYY-MM-DDThh:mm:ssZ。タイムスタンプが提供されていない場合、現在のタイムスタンプが使用されます。
バッチの有効期限	バッチアクションが送信される頻度を指定するための有効期限（TTL）を構成します。1分から60分の間で値を入力します。デフォルト値は60分です。
属性名の印刷	デフォルトでは、属性 ID がキー名として使用されます。代わりに属性名をキー名として使用する場合は、このチェックボックスを有効にします。属性名が更新されると、ペイロード内のキー名も更新されます。
ストリーミングモードを有効にする	このオプションを有効にすると、イベントをバッチ処理せずにすぐに送信します。このオプションを無効にすると、上記のバッチ制限に従ってイベントがバッチ処理されます。

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

バッチ制限

このコネクタは、ベンダーへの大量データ転送をサポートするためにバッチリクエストを使用します。並列処理により、イベントがベンダーに順不同で到達する可能性があります。順序が重要な場合は、イベントにシーケンス値を追加してください。詳細については、バッチアクションを参照してください。次のいずれかの閾値に達するか、プロファイルが公開されるまでリクエストはキューに入れられます：

• 最大リクエスト数：100
• 最古のリクエストからの最大時間：60分
• リクエストの最大サイズ：10 MB

パラメータ

パラメータ	説明
トピック ID	トピックを選択するか、トピック ID を入力します。
パーティション ID	パーティション ID を選択します。
データ形式	データ配信の形式を指定します。可能な値：JSON, STRING, BINARY。
ヘッダー	オプションのパラメータ。ヘッダーのプロパティと値をリストするキーと値のペアのセット。
メッセージキー	生のメッセージキーを指定します。データ形式として BINARY を選択した場合、Tealium はこの値をエンコードして送信します。
タイムスタンプ	ISO 8601 UTC 形式のトピックタイムスタンプ。例：YYYY-MM-DDThh:mm:ssZ。タイムスタンプが提供されていない場合、現在のタイムスタンプが使用されます。

メッセージデータ

パラメータ	説明
テンプレート変数	テンプレートにデータ入力としてテンプレート変数を提供します。 詳細情報および使用例については、テンプレート変数ガイドを参照してください。 ドット表記を使用してネストされたテンプレート変数に名前を付けます。例：items.name. ネストされたテンプレート変数は通常、データレイヤーリスト属性から構築されます。
テンプレート	メッセージデータで参照されるテンプレートを提供します。詳細については、テンプレートガイドを参照してください。 テンプレートは、サポートされるフィールドに二重中括弧で名前で注入されます。例：{{SomeTemplateName}}。
バッチの有効期限	バッチアクションが送信される頻度を指定するための有効期限（TTL）を構成します。値は 1 から 60 分の間で入力します。デフォルト値は 60 分です。
ストリーミングモードを有効にする	このオプションを有効にすると、イベントをバッチ処理せずにすぐに送信します。このオプションを無効にすると、上記のバッチ制限に従ってイベントがバッチ処理されます。

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

バッチ制限

このコネクタは、ベンダーへの大量データ転送をサポートするためにバッチリクエストを使用します。並列処理により、イベントがベンダーに順不同で到達する可能性があります。順序が重要な場合は、イベントにシーケンス値を追加してください。詳細については、バッチアクションを参照してください。次のいずれかの閾値に達するか、プロファイルが公開されるまでリクエストはキューに入れられます：

• 最大リクエスト数：100
• 最古のリクエストからの最大時間：60分
• リクエストの最大サイズ：10 MB

パラメータ

パラメータ	説明
トピックID	トピックを選択するか、トピックIDを入力してください。
パーティションID	パーティションIDを選択してください。
データ形式	データ配信の形式を指定してください。可能な値: JSON、STRING、または BINARY。
ヘッダー	オプションのパラメータ。ヘッダーのプロパティと値をリストするキーと値のペアのセットです。
メッセージキー	生のメッセージキーを指定してください。データ形式として BINARY を選択した場合、Tealiumはこの値をエンコードして送信します。
タイムスタンプ	ISO 8601 UTC形式のトピックタイムスタンプ。例: YYYY-MM-DDThh:mm:ssZ。タイムスタンプが提供されていない場合、現在のタイムスタンプが使用されます。
属性名の印刷	デフォルトでは、属性IDがキー名として使用されます。代わりに属性名をキー名として使用したい場合は、このチェックボックスを有効にしてください。属性名が更新されると、ペイロードのキー名も更新されます。
現在の訪問データを訪問データに含める	ペイロードに現在の訪問データを追加します。これには、現在の訪問イベントデータの除外がチェックされていない限り、イベント訪問データが含まれます。
現在の訪問イベントデータを除外	現在の訪問データからイベントデータを除外します。
バッチの有効期限	バッチアクションが送信される頻度を指定するための有効期限（TTL）を構成します。1から60分の間で値を入力してください。デフォルト値は60分です。

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

バッチ制限

このコネクタは、ベンダーへの大量データ転送をサポートするためにバッチリクエストを使用します。並列処理により、イベントがベンダーに順不同で到達する可能性があります。順序が重要な場合は、イベントにシーケンス値を追加してください。詳細については、バッチアクションを参照してください。リクエストは、次のいずれかの閾値が満たされるか、プロファイルが公開されるまでキューに入れられます：

• 最大リクエスト数: 100
• 最古のリクエストからの最大時間: 60分
• リクエストの最大サイズ: 10 MB

パラメータ

パラメータ	説明
トピックID	トピックを選択するか、トピックIDを入力してください。
パーティションID	パーティションIDを選択してください。
データ形式	データ配信の形式を指定してください。可能な値: JSON、STRING、または BINARY。
ヘッダー	オプションのパラメータ。ヘッダーのプロパティと値をリストするキーと値のペアのセットです。
メッセージキー	生のメッセージキーを指定してください。データ形式として BINARY を選択した場合、Tealiumはこの値をエンコードして送信します。
タイムスタンプ	ISO 8601 UTC形式のトピックタイムスタンプ。例: YYYY-MM-DDThh:mm:ssZ。タイムスタンプが提供されていない場合、現在のタイムスタンプが使用されます。

メッセージデータ

パラメータ	説明
テンプレート変数	テンプレートにデータ入力としてテンプレート変数を提供します。 詳細および使用例については、テンプレート変数ガイドを参照してください。 例: items.name.のようにドット表記でネストされたテンプレート変数を名前付けします。 ネストされたテンプレート変数は通常、データレイヤーリスト属性から構築されます。
テンプレート	メッセージデータで参照されるテンプレートを提供します。詳細については、テンプレートガイドを参照してください。 テンプレートは、サポートされるフィールドに名前で二重中括弧を使用して注入されます。例: {{SomeTemplateName}}。
バッチの有効期限	バッチアクションが送信される頻度を指定するための有効期限（TTL）を構成します。1から60分の間で値を入力してください。デフォルト値は60分です。

ログイベントの送信

パラメータ

パラメータ	説明
トピックID	トピックを選択するか、トピックIDを入力してください。
パーティションID	パーティションIDを選択してください。
データ形式	データ配信の形式を指定してください。可能な値: JSON、STRING、または BINARY。
ヘッダー	オプションのパラメータ。ヘッダーのプロパティと値をリストするキーと値のペアのセットです。
メッセージキー	生のメッセージキーを指定してください。データ形式として BINARY を選択した場合、Tealiumはこの値をエンコードして送信します。
タイムスタンプ	ISO 8601 UTC形式のトピックタイムスタンプ。例: YYYY-MM-DDThh:mm:ssZ。タイムスタンプが提供されていない場合、現在のタイムスタンプが使用されます。

メッセージデータ

パラメータ	説明
テンプレート変数	テンプレートにデータ入力としてテンプレート変数を提供します。 詳細および使用例については、テンプレート変数ガイドを参照してください。 例: items.name.のようにドット表記でネストされたテンプレート変数を名前付けします。 ネストされたテンプレート変数は通常、データレイヤーリスト属性から構築されます。
テンプレート	メッセージデータで参照されるテンプレートを提供します。詳細については、テンプレートガイドを参照してください。 テンプレートは、サポートされるフィールドに名前で二重中括弧を使用して注入されます。例: {{SomeTemplateName}}。

ログイベント全体の送信

パラメータ

パラメータ	説明
トピックID	トピックを選択するか、トピックIDを入力してください。
パーティションID	パーティションIDを選択してください。
データ形式	データ配信の形式を指定してください。可能な値: JSON、STRING、または BINARY。
ヘッダー	オプションのパラメータ。ヘッダーのプロパティと値をリストするキーと値のペアのセットです。
メッセージキー	生のメッセージキーを指定してください。データ形式として BINARY を選択した場合、Tealiumはこの値をエンコードして送信します。
タイムスタンプ	ISO 8601 UTC形式のトピックタイムスタンプ。例: YYYY-MM-DDThh:mm:ssZ。タイムスタンプが提供されていない場合、現在のタイムスタンプが使用されます。