EventBridge:GetEventStreaming

Deskripsi operasi

RAM authorization

Parameter permintaan

Elemen respons

Contoh

Respons sukses

JSONformat

{
  "Message": "The event streaming [xxxx] not existed!",
  "RequestId": "7892F480-58C9-5067-AB35-8A7BEF****",
  "Data": {
    "EventStreamingName": "rocketmq-sync",
    "Description": "RocketMQ-to-RocketMQ",
    "Source": {
      "SourceMNSParameters": {
        "RegionId": "cn-hangzhou",
        "QueueName": "demo",
        "IsBase64Decode": true
      },
      "SourceRabbitMQParameters": {
        "RegionId": "cn-hangzhou",
        "InstanceId": "i-f8z9a9mcgwri1c1i****",
        "VirtualHostName": "eb-connect",
        "QueueName": "comp"
      },
      "SourceRocketMQParameters": {
        "RegionId": "cn-hangzhou",
        "InstanceId": "i-f8zbher64dlm58pl****",
        "Topic": "topic_add_anima",
        "Tag": "v1",
        "Offset": "CONSUMEFROMLASTOFFSET",
        "GroupID": "GID_group1",
        "Timestamp": 1636597951964,
        "InstanceType": "Cloud_4\n",
        "InstanceEndpoint": "reg****-vpc.cn-zhangjiakou.aliyuncs.com\n",
        "AuthType": "ACL",
        "InstanceUsername": "xxxa",
        "InstancePassword": "xxxa",
        "InstanceVpcId": "vpc-m5e3sv4b12345****\n",
        "InstanceVSwitchIds": "vsw-m5ev8asdc6h12****\n",
        "InstanceSecurityGroupId": "sg-m5edtu24f12345****\n",
        "InstanceNetwork": "PublicNetwork",
        "BodyDataType": "Json",
        "FilterType": "Tag\n",
        "FilterSql": "index > 10",
        "VpcId": "vpc-m5e3sv4b12345****\n",
        "VSwitchIds": "vsw-m5ev8asdc6h12345****\n",
        "SecurityGroupId": "sg-m5edtu24f12345****\n",
        "Network": "PublicNetwork"
      },
      "SourceRocketMQCheckpointParameters": {
        "RegionId": "cn-hangzhou",
        "InstanceType": "Cloud_4",
        "InstanceId": "rmp-cn-jte3w******\n",
        "Topics": [
          "opic_add_anima"
        ]
      },
      "SourceApacheRocketMQCheckpointParameters": {
        "RegionId": "cn-hangzhou\n",
        "InstanceId": "MQ_INST_164901546557****_BAAN****",
        "Topics": [
          "[\"Topic_1\",\"Topic_2\"]"
        ],
        "InstanceEndpoint": "registry-vpc.cn-hangzhou.aliyuncs.com",
        "InstanceUsername": "admin",
        "InstancePassword": "123456",
        "NetworkType": "PrivateNetwork",
        "VpcId": "vpc-adw1awdw*****",
        "VSwitchId": "vsw-dwaafds****",
        "SecurityGroupId": "sg-mw43*****"
      },
      "SourceKafkaParameters": {
        "RegionId": "cn-hangzhou",
        "InstanceId": "i-bp1fbtrnqmjvgq66****",
        "Topic": "topic_empower_1642473600414",
        "ConsumerGroup": "GID_TEST",
        "OffsetReset": "latest",
        "Network": "Default",
        "VpcId": "vpc-2zehizpoendb3****",
        "VSwitchIds": "vsw-wz9qqeovkwjxlu9uc****",
        "SecurityGroupId": "sg-2vcgdxz7o1n9zapp****",
        "ValueDataType": "Text"
      },
      "SourceMQTTParameters": {
        "RegionId": "cn-shanghai",
        "InstanceId": "i-2ze06wqdwk0uq14k****",
        "Topic": "TOPIC-cainiao-pcs-wms-instock-noPrealertPrintLabel",
        "BodyDataType": "JSON",
        "NetworkType": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": ""
      },
      "SourceDTSParameters": {
        "TaskId": "f86e5814-b223-482c-b768-3b873297****",
        "BrokerUrl": "",
        "Topic": "TP_TEST_UNDERWRITE_ISSUE",
        "Sid": "HD1",
        "Username": "admin",
        "Password": "admin****",
        "InitCheckPoint": "1620962769"
      },
      "SourceSLSParameters": {
        "Project": "dmmzk",
        "LogStore": "waf-logstore",
        "ConsumerGroup": "",
        "ConsumePosition": "begin",
        "RoleName": "testRole"
      },
      "SourcePrometheusParameters": {
        "RegionId": "cn-hangzhou",
        "ClusterId": "c83555068b6******ad213f565f209\n",
        "DataType": "Json",
        "Labels": "__name__=.*\n",
        "RoleName": "test-role",
        "ExternalLabels": "{\"env\":\"test\"}"
      },
      "SourceCustomizedKafkaParameters": {
        "InstanceId": "r-8vb64581862c****\n"
      },
      "SourceCustomizedKafkaConnectorParameters": {
        "ConnectorPackageUrl": "\"https://examplebucket.oss-cn-hangzhou.aliyuncs.com/testDoc/Old_Homebrew/2024-06-26%2022%3A34%3A08/opt/homebrew/homebrew/Library/Homebrew/test/support/fixtures/cask/AppWithBinary.zip?OSSAccessKeyId=ri&Expires=1725539627&Signature=rb8q3OpV2i3gZJ\"",
        "ConnectorParameters": {
          "Name": "test-name\n",
          "Config": {
            "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector",
            "tasks.max": "1",
            "topics": "sourceA,sourceB"
          }
        },
        "WorkerParameters": {
          "group.id": "connect-eb-cluster-KAFKA_CONNECTORC",
          "offset.storage.topic": "connect-eb-offset-KAFKA_CONNECTOR_yjqC8K5ewC",
          "config.storage.topic": "connect-eb-config-KAFKA_CONNECTOR_yjqC8K5ewC",
          "status.storage.topic": "connect-eb-status-KAFKA_CONNECTOR_yjqC8K5ewC",
          "consumer.group.id": "connector-eb-cluster-KAFKA_CONNECTOR_yjqC8K5ewC-mongo-sink",
          "bootstrap.servers": "alikafka-post:9092"
        }
      },
      "SourceApacheKafkaParameters": {
        "Bootstraps": "",
        "Topic": "",
        "ConsumerGroup": "",
        "OffsetReset": "",
        "ValueDataType": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": "",
        "NetworkType": "",
        "SecurityProtocol": "",
        "SaslMechanism": "",
        "SaslUser": "",
        "SaslPassword": "",
        "SslTruststoreCertificates": "",
        "SslKeystoreCertificateChain": "",
        "SslKeyPassword": "",
        "SslKeystoreKey": {
          "KmsArn": "",
          "KmsSecretValueKey": ""
        }
      },
      "SourceOSSParameters": {
        "RoleName": "eventbridge_oss_role\n",
        "BucketName": "bucket_abc\n",
        "Prefix": "fun/document/\n",
        "LoadMode": "single\n",
        "LoadFormat": "TextLoader\n",
        "Delimiter": "\\n\n"
      },
      "SourceOpenSourceRabbitMQParameters": {
        "Endpoint": "192.168.1.100:5672",
        "VirtualHostName": "eb-connect",
        "QueueName": "demo",
        "BodyDataType": "Json",
        "Username": "admin",
        "Password": "******",
        "VpcId": "vpc-bp1vllc1lnw1v657******",
        "VSwitchIds": "vsw-uf65zhil5oukof5******",
        "SecurityGroupId": "sg-2ze65razphjfz3******",
        "NetworkType": "PrivateNetwork\n",
        "AuthType": "ACL"
      },
      "SourceEventBusParameters": {
        "EventBusName": "demo",
        "EventRuleName": "test"
      },
      "SourceMySQLParameters": {
        "RegionId": "",
        "HostName": "",
        "User": "",
        "Password": "",
        "DatabaseName": "",
        "TableNames": "",
        "NetworkType": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": "",
        "Port": 0,
        "SnapshotMode": "",
        "IncludeSchemaChanges": ""
      },
      "SourcePostgreSQLParameters": {
        "RegionId": "",
        "HostName": "",
        "Port": 0,
        "User": "",
        "Password": "",
        "DatabaseName": "",
        "SchemaName": "",
        "TableNames": "",
        "NetworkType": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": "",
        "SnapshotMode": ""
      },
      "SourceRabbitMQMetaParameters": {
        "InstanceType": "",
        "InstanceId": "",
        "Endpoint": "",
        "VirtualHostName": "",
        "Regex": "",
        "Username": "",
        "Password": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": "",
        "NetworkType": "",
        "MaxHops": "",
        "OrderConsume": "",
        "InnerNameSuffix": "",
        "SyncMetaType": ""
      },
      "SourceRabbitMQMsgSyncParameters": {
        "InstanceType": "",
        "InstanceId": "",
        "Endpoint": "",
        "VirtualHostName": "",
        "OrderConsume": "",
        "BodyDataType": "",
        "PrefetchCount": "",
        "Username": "",
        "Password": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": "",
        "NetworkType": "",
        "SyncMetaType": "",
        "Regex": "",
        "SrcClusterType": "",
        "SrcClusterHost": "",
        "DstClusterType": "",
        "DstClusterHost": "",
        "CloudMigrationTaskId": ""
      },
      "SourceFeiShuDocsParameters": {
        "AppId": "",
        "AppSecret": "",
        "KnowledgeSpaceName": "",
        "LoadMode": ""
      },
      "SourceJDBCParameters": {
        "JdbcUrl": "",
        "Username": "",
        "Password": "",
        "QueryMode": "",
        "TableName": "",
        "IncrementingColumn": "",
        "TimestampColumn": "",
        "PollingInterval": 0,
        "BatchSize": 0,
        "QueryTimeout": 0,
        "CustomQuery": "",
        "Network": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": ""
      }
    },
    "Metadata": "",
    "FilterPattern": "",
    "Transforms": [
      {
        "Arn": "acs:fc:cn-hangzhou:*****:services/demo-service.LATEST/functions/demo-func\n",
        "DashScopeTransformParameters": {
          "Model": "",
          "ApiKey": "",
          "StructuredOutputJsonSchema": "",
          "RequestPerMinute": 0,
          "TokenPerMinute": 0,
          "Messages": [
            {
              "Role": "",
              "Form": "",
              "Value": "",
              "Template": ""
            }
          ]
        },
        "BaiLianAgentTransformParameters": {
          "ApplicationId": "",
          "Prompt": {
            "Form": "",
            "Value": "",
            "Template": ""
          },
          "ApiKey": "",
          "RequestPerMinute": 0,
          "TokenPerMinute": 0
        }
      }
    ],
    "Sink": {
      "SinkMNSParameters": {
        "QueueName": {
          "Value": "MyQueue",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Body": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!"
        },
        "IsBase64Encode": {
          "Value": "true",
          "Form": "CONSTANT",
          "Template": ""
        }
      },
      "SinkRabbitMQParameters": {
        "InstanceId": {
          "Value": "e5c9b727-e06c-4d7e-84d5-f8ce644e****",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "VirtualHostName": {
          "Value": "rabbit-host\n",
          "Form": "CONSTANT",
          "Template": ""
        },
        "TargetType": {
          "Value": "Exchange/Queue",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Exchange": {
          "Value": "a_exchange",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "RoutingKey": {
          "Value": "housekeeping",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "QueueName": {
          "Value": "MyQueue",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Body": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!"
        },
        "MessageId": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!"
        },
        "Properties": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n"
        }
      },
      "SinkFcParameters": {
        "ServiceName": {
          "Value": "myService",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "FunctionName": {
          "Value": "mFunction",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Concurrency": {
          "Value": "1",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Qualifier": {
          "Value": "LATEST",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "InvocationType": {
          "Value": "Async",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Body": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "DataFormat": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "JSONPATH",
          "Template": "$.data.key"
        }
      },
      "SinkKafkaParameters": {
        "InstanceId": {
          "Value": "Defaut_1283278472_s****",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "DynamicTopic": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "Topic": {
          "Value": "test",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "CompressionType": "",
        "Acks": {
          "Value": "1",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Key": {
          "Value": "key",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Headers": {
          "Value": "{\n      \"key\": \"value\"\n}\n\n",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Value": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n"
        }
      },
      "SinkApacheKafkaParameters": {
        "Bootstraps": "",
        "Topic": "",
        "DynamicTopic": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "Acks": "",
        "CompressionType": "",
        "Key": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "Headers": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "Value": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "SecurityProtocol": "",
        "SaslMechanism": "",
        "SaslUser": "",
        "VpcId": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "VSwitchIds": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "SecurityGroupId": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "NetworkType": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "SaslPassword": "",
        "SslTruststoreCertificates": "",
        "SslKeystoreCertificateChain": "",
        "SslKeyPassword": "",
        "SslKeystoreKey": {
          "KmsArn": "",
          "KmsSecretValueKey": ""
        }
      },
      "SinkRocketMQParameters": {
        "InstanceId": {
          "Value": "MQ_INST_164901546557****_BAAN****",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Topic": {
          "Value": "Mytopic",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Body": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Properties": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Keys": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!"
        },
        "Tags": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!"
        },
        "InstanceType": {
          "Value": "Cloud_4\n",
          "Form": "CONSTANT",
          "Template": ""
        },
        "InstanceEndpoint": {
          "Value": "vbr-8vbsvkkbpf3vb0zef****\n",
          "Form": "CONSTANT\n",
          "Template": ""
        },
        "InstanceUsername": {
          "Value": "admin\n",
          "Form": "CONSTANT\n",
          "Template": ""
        },
        "InstancePassword": {
          "Value": "admin****\n",
          "Form": "CONSTANT\n",
          "Template": ""
        },
        "VpcId": {
          "Value": "vbr-8vb835n3zf9shwlvb****\n",
          "Form": "CONSTANT\n",
          "Template": "\n"
        },
        "VSwitchIds": {
          "Value": "vbr-8vb835n3zf9shwl****mp\n",
          "Form": "CONSTANT\n",
          "Template": "\n"
        },
        "SecurityGroupId": {
          "Value": "b4bf375515f6440f942e3a20c33d****\n",
          "Form": "CONSTANT\n",
          "Template": ""
        },
        "Network": {
          "Value": "PublicNetwork\n",
          "Form": "CONSTANT\n",
          "Template": "\n"
        },
        "DeliveryOrderType": {
          "Value": "Concurrently",
          "Form": "CONSTANT",
          "Template": ""
        },
        "ShardingKey": {
          "Value": "order_id",
          "Form": "CONSTANT",
          "Template": ""
        }
      },
      "SinkDorisParameters": {
        "QueryEndpoint": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "FeHttpEndpoint": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "BeHttpEndpoint": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "UserName": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "Password": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "Database": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "Table": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "Body": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "NetworkType": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "VpcId": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "VSwitchIds": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "SecurityGroupId": {
          "Value": "",
          "Form": "",
          "Template": ""
        }
      },
      "SinkRocketMQCheckpointParameters": {
        "InstanceType": "Cloud_4",
        "InstanceId": "MQ_INST_164901546557****_BAAN****",
        "Topic": {
          "Value": "Mytopic",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Group": {
          "Value": "GID_EVENTBRIDGE_1736234******",
          "Form": "CONSTANT",
          "Template": ""
        },
        "ConsumeTimestamp": {
          "Value": "1570761026400",
          "Form": "CONSTANT",
          "Template": ""
        }
      },
      "SinkApacheRocketMQCheckpointParameters": {
        "Topic": {
          "Value": "Mytopic",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Group": {
          "Value": "GID_EVENTBRIDGE_1736234******\n",
          "Form": "CONSTANT",
          "Template": ""
        },
        "ConsumeTimestamp": {
          "Value": "1570761026400",
          "Form": "CONSTANT",
          "Template": ""
        },
        "InstanceEndpoint": "192.168.1.1:9876",
        "InstanceUsername": "admin",
        "InstancePassword": "****",
        "NetworkType": "PrivateNetwork",
        "VpcId": "vpc-2zeccak5pb0j3ay******",
        "VSwitchId": "vsw-uf62oqt1twuevrt******",
        "SecurityGroupId": "sg-2ze5bmpw6adn0q******"
      },
      "SinkSLSParameters": {
        "Project": {
          "Value": "test-project\n",
          "Form": "CONSTANT",
          "Template": ""
        },
        "LogStore": {
          "Value": "test-logstore",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Topic": {
          "Value": "testTopic",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Body": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "RoleName": {
          "Value": "testRole",
          "Form": "CONSTANT",
          "Template": ""
        },
        "ContentType": {
          "Value": "JSON\n",
          "Form": "CONSTANT\n",
          "Template": ""
        },
        "ContentSchema": {
          "Value": "{\"Key_1\":{\"form\":\"CONSTANT\",\"value\":\"demoKey\"},\"Value_1\":{\"form\":\"JSONPATH\",\"value\":\"$.data.value\"}}",
          "Form": "CONSTANT\n",
          "Template": ""
        }
      },
      "SinkFnfParameters": {
        "FlowName": {
          "Value": "test-streaming-fnf",
          "Form": "CONSTANT",
          "Template": ""
        },
        "ExecutionName": {
          "Value": "123",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Input": {
          "Value": "123",
          "Form": "CONSTANT",
          "Template": ""
        },
        "RoleName": {
          "Value": "Al****FNF-x****",
          "Form": "CONSTANT",
          "Template": ""
        }
      },
      "SinkDataHubParameters": {
        "Project": {
          "Value": "demo-project\n",
          "Form": "CONSTANT\n",
          "Template": "\n\n"
        },
        "Topic": {
          "Value": "demo-topic\n",
          "Form": "CONSTANT",
          "Template": ""
        },
        "TopicType": {
          "Value": "TUPLE\n",
          "Form": "CONSTANT",
          "Template": ""
        },
        "TopicSchema": {
          "Value": "{\"k1\":\"value1\",\"k2\":\"value2\"}",
          "Form": "TEMPLATE",
          "Template": "{\"k1\":\"${k1}\",\"k2\":\"${k2}\"}"
        },
        "Body": {
          "Value": "",
          "Form": "ORIGINAL",
          "Template": ""
        },
        "RoleName": {
          "Value": "test-role",
          "Form": "CONSTANT",
          "Template": ""
        }
      },
      "SinkCustomizedKafkaParameters": {
        "InstanceId": "90be1f96-4229-4535-bb76-34b4f6fb****"
      },
      "SinkCustomizedKafkaConnectorParameters": {
        "ConnectorPackageUrl": "\"https://examplebucket.oss-cn-hangzhou.aliyuncs.com/testDoc/Old_Homebrew/2024-06-26%2022%3A34%3A08/opt/homebrew/homebrew/Library/Homebrew/test/support/fixtures/cask/AppWithBinary.zip?OSSAccessKeyId=ri&Expires=1725539627&Signature=rb8q3OpV******\"",
        "ConnectorParameters": {
          "Name": "mongo-sink",
          "Config": {
            "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector",
            "tasks.max": "1",
            "topics": "sourceA,sourceB"
          }
        },
        "WorkerParameters": {
          "group.id": "connect-eb-cluster-KAFKA_CONNECTORC",
          "offset.storage.topic": "connect-eb-offset-KAFKA_CONNECTOR_yjqC8K5ewC",
          "config.storage.topic": "connect-eb-config-KAFKA_CONNECTOR_yjqC8K5ewC",
          "status.storage.topic": "connect-eb-status-KAFKA_CONNECTOR_yjqC8K5ewC",
          "consumer.group.id": "connector-eb-cluster-KAFKA_CONNECTOR_yjqC8K5ewC-mongo-sink",
          "bootstrap.servers": "alikafka-post:9092"
        }
      },
      "SinkDashVectorParameters": {
        "InstanceId": "vrs-cn-lbj3ru1***",
        "Collection": "collection1",
        "ApiKey": "Q34nExQH7sQ****",
        "Operation": "Upsert",
        "Network": "PublicNetwork",
        "PrimaryKeyId": {
          "Form": "JSONPATH",
          "Value": "$.data.requestId",
          "Template": "${ID}"
        },
        "Partition": {
          "Form": "CONSTANT",
          "Value": "default",
          "Template": ""
        },
        "Vector": {
          "Form": "JSONPATH",
          "Value": "$.data.messageBody",
          "Template": ""
        },
        "DashVectorSchemaParameters": [
          {
            "Name": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Type": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Value": {
              "Form": "",
              "Value": "",
              "Template": ""
            }
          }
        ]
      },
      "SinkOpenSourceRabbitMQParameters": {
        "Endpoint": "192.168.1.1:9876",
        "VirtualHostName": "vhost1",
        "TargetType": "Exchange",
        "Exchange": "my-exchange",
        "QueueName": "my-queue",
        "Username": "admin",
        "Password": "****",
        "VpcId": "vpc-uf6of9452b2pba82c ****",
        "VSwitchIds": "vsw-uf6of9452b2pba82c ****",
        "SecurityGroupId": "sg-uf6of9452b2pba82c ****",
        "NetworkType": "PublicNetwork\n",
        "AuthType": "ACL",
        "RoutingKey": {
          "Form": "CONSTANT",
          "Value": "{\"Form\": \"CONSTANT\", \"Value\": \"my-routing-key\"}\n",
          "Template": "The value of ${key} is ${value}!"
        },
        "Body": {
          "Form": "CONSTANT",
          "Value": "{\"key\": \"value\"}",
          "Template": "The value of ${key} is ${value}!"
        },
        "MessageId": {
          "Form": "CONSTANT",
          "Value": "12345",
          "Template": ""
        },
        "Properties": {
          "Form": "CONSTANT",
          "Value": "{\"env\": \"prod\"}",
          "Template": "The value of ${key} is ${value}!\n"
        }
      },
      "SinkBaiLianParameters": {
        "WorkspaceId": "",
        "ApplicationType": "",
        "Before": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "After": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Context": "",
        "Extend": "",
        "Op": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Partition": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Offset": {
          "Form": "",
          "Value": "",
          "Template": ""
        }
      },
      "SinkDataWorksTriggerParameters": {
        "Enable": ""
      },
      "SinkHttpsParameters": {
        "URL": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Method": "",
        "Body": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Token": "",
        "NetworkType": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": ""
      },
      "SinkApiDestinationParameters": {
        "Name": "",
        "HeaderParameters": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "BodyParameters": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "QueryStringParameters": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Timeout": 0
      },
      "SinkOSSParameters": {
        "BucketName": "",
        "RegionId": "",
        "Endpoint": "",
        "RoleArn": "",
        "RotateSizeBytes": "",
        "RotateIntervalMs": "",
        "PathFormat": "",
        "CompressionType": "",
        "TaskConcurrency": "",
        "TimeZone": "",
        "SSLEnabled": false,
        "ContentTransform": {
          "Form": "",
          "Value": "",
          "Template": ""
        }
      },
      "SinkRabbitMQMetaParameters": {
        "InstanceType": "",
        "InstanceId": "",
        "Endpoint": "",
        "VirtualHostName": "",
        "Username": "",
        "Password": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": "",
        "NetworkType": ""
      },
      "SinkRabbitMQMsgSyncParameters": {
        "InstanceType": "",
        "InstanceId": "",
        "Endpoint": "",
        "VirtualHostName": "",
        "Body": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "MessageId": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Properties": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Exchange": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "RoutingKey": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "MaxHops": "",
        "Username": "",
        "Password": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": "",
        "NetworkType": ""
      },
      "SinkMQTTParameters": {
        "InstanceId": "",
        "ParentTopic": "",
        "SubTopic": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Payload": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Mqtt5UserProperty": {
          "Form": "",
          "Value": "",
          "Template": ""
        }
      },
      "SinkAgentRunParameters": {
        "AgentRuntimeName": "",
        "EndpointName": "",
        "RoleName": "",
        "Body": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "Timeout": ""
      }
    },
    "RunOptions": {
      "MaximumTasks": 2,
      "RetryStrategy": {
        "PushRetryStrategy": "BACKOFF_RETRY",
        "MaximumEventAgeInSeconds": 512,
        "MaximumRetryAttempts": 2
      },
      "ErrorsTolerance": "ALL",
      "DeadLetterQueue": {
        "Arn": "acs:ram::155020394332****:role/edskmstoecs",
        "Network": "PrivateNetwork",
        "VpcId": "vpc-2zehizpoendb3****",
        "VSwitchIds": "vsw-m5ev8asdc6h12345****",
        "SecurityGroupId": "sg-2vcgdxz7o1n9zapp****"
      },
      "BatchWindow": {
        "CountBasedWindow": 100,
        "TimeBasedWindow": 10
      },
      "BusinessOption": {
        "BusinessMode": "",
        "MinCapacityUnitCount": 0,
        "MaxCapacityUnitCount": 0
      },
      "Throttling": 0
    },
    "Status": "RUNNING",
    "DetailedStatus": {
      "TPS": 5,
      "DelayTime": 3,
      "DiffOffset": 0,
      "Extensions": {
        "test": "test",
        "test2": 1
      }
    }
  },
  "Code": "Success",
  "Success": true
}

Kode kesalahan

Catatan rilis