REST APIリファレンス

前へ次へ

Kafkaをソースおよびターゲットとするタスクの接続構成

タスクのソース接続とターゲット接続がKafkaの場合、ソース接続とターゲット接続の構成配列に次のフィールドおよびキーと値のペアを含めることができます。

キー	タイプ	必須	説明
Topic	String	○	イベントの読み取り元となるKafkaソーストピック名、またはJavaでサポートされているKafkaソーストピック名パターンの正規表現。 249文字までの文字列を入力します。
consumerProperties	String	-	オプションのコンシューマ設定プロパティのカンマ区切りリストを指定します。キーと値のペアとして値を指定します。例: key1=value1, key2=value2 4000文字までの文字列を入力できます。
producerProperties	String	-	プロデューサの設定プロパティ。カンマ区切りリストを指定し、値をキーと値のペアとして指定します。 4000文字までの文字列を入力できます。
mdFetchTimeout	Integer	-	それ以降にメタデータが取得されなくなる時間。 1～2147483647の範囲で値を入力してください。
batchSize	Integer	-	ストリーミング取り込みタスクがそれ以降なターゲットにデータを書き込むイベントのバッチサイズ。 1～2147483647の範囲で値を入力してください。
Topic Name/Expression	String	○	Kafkaトピック名またはJavaがサポートするKafkaトピック名パターンの正規表現。 249文字までの文字列を入力できます。

POST要求の例

KafkaソースとKafkaターゲットを使用する

ストリーミング統合

タスクを更新するには、次の例のような要求を送信できます。

{
  "name": "kafka to kafka",
  "description": "kafka to kafka",
  "runtimeId": "01000025000000000003",
  "locationId": "5sJ0JDyJyWLlrosS5qJjsQ",
  "currentVersion": "2",
  "messageFormat": "binary",
  "nodes": [
    {
      "name": "kafka to kafka_source",
      "type": "source",
      "connectionId": "012MGS0B000000000002",
      "transformationType": "",
      "config": [
        {
          "key": "consumerProperties",
          "value": "key=value"
        },
        {
          "key": "Topic",
          "value": "test"
        }
      ]
    },
    {
      "name": "kafka to kafka_target",
      "type": "target",
      "connectionId": "012MGS0B000000000002",
      "transformationType": "",
      "config": [
        {
          "key": "producerProperties",
          "value": "key=value"
        },
        {
          "key": "mdFetchTimeout",
          "value": 5000
        },
        {
          "key": "batchSize",
          "value": 1048576
        },
        {
          "key": "Topic Name/Expression",
          "value": "test"
        }
      ]
    }
  ],
  "edges": [
    {
      "from": "kafka to kafka_source",
      "to": "kafka to kafka_target"
    }
  ]
}

POST要求

ガイドをダウンロード

ページをウォッチ

フィードバックを送信

コミュニティ

Knowledge Base

Success Portal

Rename Saved Search

目次

REST APIリファレンス

REST APIリファレンス

Kafkaをソースおよびターゲットとするタスクの接続構成

Kafkaをソースおよびターゲットとするタスクの接続構成

POST要求の例