Confluent Kafka Connect コネクタ構成ガイド
この記事では、Confluent Kafka Connect コネクタの構成方法について説明します。
構成
コネクタマーケットプレイスにアクセスし、新しいコネクタを追加します。コネクタを追加する一般的な手順については、コネクタについてを参照してください。
コネクタを追加した後、以下の構成を行います:
- API キー:(必須)Confluent API キー。
- API シークレット:(必須)Confluent API シークレット。
- ブートストラップサーバー:(必須)Confluent ブートストラップサーバー。プロトコルやパスは含めないでください。例えば、
https://confluent.bootstrap.server:443はconfluent.bootstrap.serverとしてください。 - クラスター ID:(必須)Kafka クラスター ID。
アクション
| アクション名 | 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。タイムスタンプが提供されていない場合、現在のタイムスタンプが使用されます。 |
最終更新日 :: 2026年January月22日