{
"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": "2",
"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"
},
"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"
},
"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": {
"ClusterId": "c83555068b6******ad213f565f209\n",
"DataType": "json",
"Labels": "__name__=.*\n"
}
},
"FilterPattern": "无",
"Transforms": [
{
"Arn": "acs:fc:cn-hangzhou:*****:services/demo-service.LATEST/functions/demo-func\n"
}
],
"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": "无"
},
"VirtualHostName": {
"Value": "rabbit-host\n",
"Form": "CONSTANT",
"Template": "无"
},
"TargetType": {
"Value": "Exchange/Queue",
"Form": "CONSTANT",
"Template": "无"
},
"Exchange": {
"Value": "a_exchange",
"Form": "CONSTANT",
"Template": "无"
},
"RoutingKey": {
"Value": "housekeeping",
"Form": "CONSTANT",
"Template": "无"
},
"QueueName": {
"Value": "MyQueue",
"Form": "CONSTANT",
"Template": "无"
},
"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": "无"
},
"FunctionName": {
"Value": "mFunction",
"Form": "CONSTANT",
"Template": "无"
},
"Concurrency": {
"Value": "1",
"Form": "CONSTANT",
"Template": "无"
},
"Qualifier": {
"Value": "LATEST",
"Form": "CONSTANT",
"Template": "无"
},
"InvocationType": {
"Value": "Async",
"Form": "CONSTANT",
"Template": "无"
},
"Body": {
"Value": "{\n \"key\": \"value\"\n}",
"Form": "TEMPLATE",
"Template": "The value of ${key} is ${value}!\n"
}
},
"SinkKafkaParameters": {
"InstanceId": {
"Value": "Defaut_1283278472_s****",
"Form": "CONSTANT",
"Template": "无"
},
"Topic": {
"Value": "topic-test",
"Form": "CONSTANT",
"Template": "无"
},
"Acks": {
"Value": "1",
"Form": "CONSTANT",
"Template": "无"
},
"Key": {
"Value": "key",
"Form": "CONSTANT",
"Template": "无"
},
"Value": {
"Value": "{\n \"key\": \"value\"\n}",
"Form": "TEMPLATE",
"Template": "The value of ${key} is ${value}!\n"
}
},
"SinkRocketMQParameters": {
"InstanceId": {
"Value": "MQ_INST_164901546557****_BAAN****",
"Form": "CONSTANT",
"Template": "无"
},
"Topic": {
"Value": "Mytopic",
"Form": "CONSTANT",
"Template": "无"
},
"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}!"
}
},
"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": "无"
}
},
"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": "无"
}
}
},
"RunOptions": {
"MaximumTasks": 2,
"RetryStrategy": {
"PushRetryStrategy": "BACKOFF_RETRY",
"MaximumEventAgeInSeconds": 512,
"MaximumRetryAttempts": 2
},
"ErrorsTolerance": "ALL",
"DeadLetterQueue": {
"Arn": "acs:ram::155020394332****:role/edskmstoecs"
},
"BatchWindow": {
"CountBasedWindow": 100,
"TimeBasedWindow": 10
}
},
"Status": "RUNNING"
},
"Code": "Success",
"Success": true
}