目次

Search

  1. はじめに
  2. Informatica Intelligent Cloud Services REST API
  3. プラットフォームREST APIバージョン2リソース
  4. プラットフォームREST APIバージョン3リソース
  5. データ統合 REST API
  6. 一括取り込みファイルREST API
  7. 一括取り込みストリーミングREST API
  8. Model Serve REST API
  9. RunAJobユーティリティ
  10. ParamSetCliユーティリティ
  11. REST APIコード
  12. REST APIリソースクイックリファレンス

REST APIリファレンス

REST APIリファレンス

Kafkaをソースおよびターゲットとする場合の構成配列内の構成情報

Kafkaをソースおよびターゲットとする場合の構成配列内の構成情報

応答は、要求で入力したフィールドのみを返します。
要求が成功した場合、応答は次のフィールドを返します。
キー
タイプ
説明
Topic
String
イベントの読み取り元となるKafkaソーストピック名、またはJavaでサポートされているKafkaソーストピック名パターンの正規表現。
consumerProperties
String
オプションのコンシューマ設定プロパティのカンマ区切りリスト。
producerProperties
String
プロデューサの設定プロパティ。
mdFetchTimeout
Integer
それ以降にメタデータが取得されなくなる時間。
batchSize
Integer
ストリーミング取り込みタスクがそれ以降なターゲットにデータを書き込むイベントのバッチサイズ。
Topic Name/Expression
String
Kafkaトピック名またはJavaがサポートするKafkaトピック名パターンの正規表現。
要求が失敗すると、応答にエラーの理由が含まれます。

POST応答の例

要求が成功した場合、
Success
ノードで次の例のような応答を受信することがあります。
{ "Success": { "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" } ] } }