apache / apache/rocketmq-connect

rocketmq-replicator API non mandatory parameters does not pass

Open
#491 2 comments 0 reactions 0 assignees View on GitHub
Dominant language
Java
Stars
141
Forks
120
PR merge metrics
No merged PRs in 30d

Description

This is my API request:
curl -X POST -H "Content-Type: application/json" http://127.0.0.1:8082/connectors/test002 -d '{
"connector.class": "org.apache.rocketmq.replicator.ReplicatorSourceConnector",
"src.endpoint": "127.0.0.1:9876",
"src.cluster": "DefaultCluster",
"dest.acl.enable": "false",
"dest.topic": "test-002",
"max.task": "2",
"src.topictags": "test-002,*",
"src.acl.enable": "false",
"dest.endpoint": "192.168.90.22:9876",
"dest.cluster": "DefaultCluster",
}'

API response:
{"errorCode":500,"message":"Replicator connector org.apache.rocketmq.replicator.ReplicatorSourceConnector do not set dest.cloud"}

According to README.md rocketmq-replicator参数说明,“dest.cloud” Not mandatory
https://github.com/apache/rocketmq-connect/tree/master/connectors/rocketmq-replicator

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.