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

この記事では、Confluent Kafka Connectコネクタの構成方法について説明します。

コネクタのアクション

アクション名	AudienceStream	EventStream
トピックへのデータ投稿	✓	✓

構成の構成

コネクタマーケットプレイスに移動し、新しいコネクタを追加します。コネクタの追加方法の一般的な指示については、コネクタについてを参照してください。

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

APIキー
必須。Confluent APIキー。
APIシークレット
必須。Confluent APIシークレット。
ブートストラップサーバー
必須。Confluentブートストラップサーバー。プロトコルやパスを含めないでください。例えば、https://confluent.bootstrap.server:443はconfluent.bootstrap.serverとするべきです。
クラスターID
必須。KafkaクラスターID。

アクション

アクションの名前を入力し、ドロップダウンメニューからアクションタイプを選択します。

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

トピックへのデータ投稿

パラメータ

パラメータ	説明
トピックID	トピックを選択するか、トピックIDを入力します。
パーティションID	パーティションID。
キー（BINARY）	バイナリタイプのキーパラメータの値。
キー（JSON）	JSONタイプのキーパラメータの値。
値（BINARY）	バイナリタイプの値パラメータの値。
値（JSON）	JSONタイプの値パラメータの値。
タイムスタンプ	ISO 8601 UTC形式のトピックタイムスタンプ ‘YYYY-MM-DDThh:mm:ssZ’。タイムスタンプが提供されていない場合、現在のタイムスタンプが使用されます。
ヘッダー	オプションのパラメータ：ヘッダープロパティと値のキー-値ペアのリスト。
テンプレート変数	テンプレートのデータ入力としてテンプレート変数を提供します。使用例については、テンプレート変数ガイドのドキュメンテーションを参照してください。ネストしたテンプレート変数はドット表記法で名前を付けます。例：`items.name`。ネストしたテンプレート変数は通常、データレイヤーリスト属性から作成されます。
テンプレート	ボディパラメータで参照されるテンプレートを提供します。テンプレートガイドを参照してください。テンプレートは、例えば`{{SomeTemplateName}}`のように、サポートされるフィールドに名前で注入されます。

このページはお役にたちましたでしょうか？

最終更新日 :: 2024年March月29日