youngkangrui opened a new issue, #122:
URL: https://github.com/apache/rocketmq-connect/issues/122

   i found some wrong messages when i try to reaapear the example followinig 
the guide  
[quick-start](https://rocketmq-1.gitbook.io/rocketmq-connector/quick-start/file-connector)
   1. “两套RocketMQ集群环境”应该改为“一套RocketMQ集群环境”,因为file的record发送和file的record消费是一套集群, 
<img width="975" alt="截屏2022-05-03 下午1 11 32" 
src="https://user-images.githubusercontent.com/23549507/166407301-0e3d5afd-6186-4e07-8e9a-2cb2e3741b99.png";>
   2. ”source connector启动“目录下的”topic“都应该改为“connect-topicname”
   <img width="1169" alt="截屏2022-05-03 下午1 19 34" 
src="https://user-images.githubusercontent.com/23549507/166407603-5aa020b9-eca6-4e21-b7c2-49a229d2a784.png";>
   3. “sink connector启动”目录下的”topic“都应该改为“connect-topicname”
   
   finally i want to show commond line to start the file-connector, if anyone 
needed
   1. wget 
--post-data='{"connector-class":"org.apache.rocketmq.connect.file.FileSourceConnector","connect-topicname":"fileTopic","filename":"/home/lighthouse/source-file.txt","source-record-converter":"org.apache.rocketmq.connect.runtime.converter.JsonConverter"}'
 http://localhost:8081/connectors/fileConnectorSource
   
   2. wget 
--post-data='{"connector-class":"org.apache.rocketmq.connect.file.FileSinkConnector","connect-topicname":"fileTopic","filename":"/home/lighthouse/sink-file.txt","source-record-converter":"org.apache.rocketmq.connect.runtime.converter.JsonConverter"}'
 http://localhost:8081/connectors/fileConnectorSink


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to