You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2021/09/01 02:42:08 UTC
[GitHub] [rocketmq-externals] lizhiboo commented on issue #804: rocketmq-replicator
lizhiboo commented on issue #804:
URL: https://github.com/apache/rocketmq-externals/issues/804#issuecomment-909823095
> 是否有 rocketmq-replicator更详细的部署文档,根据官方文档部署不生效.
>
> 1. 创建俩套rocketmq 版本V4.5.1
> 2. 源mq 创建topic如下
> connector-cluster-topic
> connector-config-topic
> connector-offset-topic
> connector-position-topic
> replicatorTopic
> 3. 配置文件
>
> ```
> #current cluster node uniquely identifies
> workerId=DEFAULT_WORKER_1
>
> ## Http port for user to access REST API
> httpPort=8081
>
> # Rocketmq namesrvAddr
> namesrvAddr=192.168.254.131:9876
>
> # Source or sink connector jar file dir,The default value is rocketmq-connect-sample
> #pluginPaths=/usr/local/connector-plugins
> pluginPaths=/home/zhuozl/rocketmq/connector-plugins
>
> # Local file dir for config store
> storePathRootDir=/home/zhuozl/rocketmq/storeRoot
> ```
>
> 1. 启动 sh ./run_worker.sh
>
> ```
> 2021-08-31 20:33:56 INFO pool-3-thread-1 - Source task producer shutdown.
> 2021-08-31 20:33:56 INFO pool-3-thread-2 - Source task producer shutdown.
> 2021-08-31 20:33:59 ERROR RmqSourceReplicator-SourceWatcher-1 - Fetch topic list error.
> org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <null> failed
> at org.apache.rocketmq.remoting.netty.NettyRemotingClient.invokeSync(NettyRemotingClient.java:392) ~[rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar:na]
> at org.apache.rocketmq.client.impl.MQClientAPIImpl.getTopicListFromNameServer(MQClientAPIImpl.java:1358) ~[rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar:na]
> at org.apache.rocketmq.tools.admin.DefaultMQAdminExtImpl.fetchAllTopicList(DefaultMQAdminExtImpl.java:246) ~[rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar:na]
> at org.apache.rocketmq.tools.admin.DefaultMQAdminExt.fetchAllTopicList(DefaultMQAdminExt.java:212) ~[rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar:na]
> at org.apache.rocketmq.replicator.RmqSourceReplicator.buildRoute(RmqSourceReplicator.java:235) ~[rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar:na]
> at org.apache.rocketmq.replicator.RmqSourceReplicator$1.run(RmqSourceReplicator.java:146) ~[rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar:na]
> at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[na:na]
> at java.base/java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) ~[na:na]
> at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[na:na]
> at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[na:na]
> at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[na:na]
> at java.base/java.lang.Thread.run(Thread.java:829) ~[na:na]
> 2021-08-31 20:33:59 INFO NettyClientSelector_1 - closeChannel: close the connection to remote address[] result: true
> 2021-08-31 20:33:59 ERROR RmqSourceReplicator-SourceWatcher-1 - Fetch topic list error.
> org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <null> failed
>
>
> 2021-08-31 20:33:56 WARN pool-3-thread-2 - Rocketmq replicator task is not started.
> 2021-08-31 20:33:56 WARN pool-3-thread-1 - Rocketmq replicator task is not started.
> 2021-08-31 20:33:56 WARN pool-3-thread-2 - Rocketmq replicator task is not started.
> 2021-08-31 20:33:56 WARN pool-3-thread-1 - Rocketmq replicator task is not started.
> 2021-08-31 20:33:56 WARN pool-3-thread-2 - Rocketmq replicator task is not started.
> 2021-08-31 20:33:56 WARN pool-3-thread-1 - Rocketmq replicator task is not started.
> 2021-08-31 20:33:56 WARN pool-3-thread-2 - Rocketmq replicator task is not started.
> 2021-08-31 20:33:56 WARN pool-3-thread-1 - Rocketmq replicator task is not started.
> 2021-08-31 20:33:56 WARN pool-3-thread-2 - Rocketmq replicator task is not started.
> 2021-08-31 20:33:56 WARN pool-3-thread-1 - Rocketmq replicator task is not started.
> 2021-08-31 20:33:56 WARN pool-3-thread-2 - Rocketmq replicator task is not started.
> 2021-08-31 20:33:56 WARN pool-3-thread-1 - Rocketmq replicator task is not started.
> 2021-08-31 20:33:56 WARN pool-3-thread-2 - Rocketmq replicator task is not started.
> ```
IMO, maybe namesrv address is not correct. Make sure rocketmq cluster works.
--
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: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org