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 09:44:03 UTC
[GitHub] [rocketmq-externals] zhuozl opened a new issue #804: rocketmq-replicator
zhuozl opened a new issue #804:
URL: https://github.com/apache/rocketmq-externals/issues/804
是否有 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
```
3. 启动 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.
```
--
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
[GitHub] [rocketmq-externals] zhuozl commented on issue #804: rocketmq-replicator
Posted by GitBox <gi...@apache.org>.
zhuozl commented on issue #804:
URL: https://github.com/apache/rocketmq-externals/issues/804#issuecomment-909837000
```
11:08:51.787 [main] INFO o.a.r.connect.runtime.utils.Plugin - Loading plugin from: /home/zhuozl/rocketmq/connector-plugins/rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar
11:08:51.844 [main] DEBUG o.a.r.connect.runtime.utils.Plugin - Loading plugin urls: [file:/home/zhuozl/rocketmq/connector-plugins/rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar]
11:08:52.428 [main] DEBUG org.reflections.Reflections - going to scan these urls:
file:/home/zhuozl/rocketmq/connector-plugins/rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar
11:08:52.640 [org.reflections-scanner-0] DEBUG org.reflections.Reflections - [Thread[org.reflections-scanner-0,5,main]] scanning file:/home/zhuozl/rocketmq/connector-plugins/rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar
11:08:52.831 [org.reflections-scanner-0] DEBUG org.reflections.Reflections - could not scan file META-INF/MANIFEST.MF in url file:/home/zhuozl/rocketmq/connector-plugins/rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar with scanner SubTypesScanner
org.reflections.ReflectionsException: could not create class object from file META-INF/MANIFEST.MF
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:32) ~[reflections-0.9.11.jar:na]
at org.reflections.Reflections.scan(Reflections.java:253) ~[reflections-0.9.11.jar:na]
at org.apache.rocketmq.connect.runtime.utils.Plugin$PluginReflections.scan(Plugin.java:120) [classes/:na]
at org.reflections.Reflections$1.run(Reflections.java:198) [reflections-0.9.11.jar:na]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run(FutureTask.java) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_91]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
Caused by: org.reflections.ReflectionsException: could not create class file from MANIFEST.MF
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:102) ~[reflections-0.9.11.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:24) ~[reflections-0.9.11.jar:na]
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:30) ~[reflections-0.9.11.jar:na]
... 9 common frames omitted
Caused by: java.io.IOException: bad magic number: 4d616e69
at javassist.bytecode.ClassFile.read(ClassFile.java:825) ~[javassist-3.21.0-GA.jar:na]
at javassist.bytecode.ClassFile.<init>(ClassFile.java:154) ~[javassist-3.21.0-GA.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:100) ~[reflections-0.9.11.jar:na]
... 11 common frames omitted
11:08:53.019 [org.reflections-scanner-0] DEBUG org.reflections.Reflections - could not scan file META-INF/maven/org.slf4j/slf4j-api/pom.xml in url file:/home/zhuozl/rocketmq/connector-plugins/rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar with scanner SubTypesScanner
org.reflections.ReflectionsException: could not create class object from file META-INF/maven/org.slf4j/slf4j-api/pom.xml
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:32) ~[reflections-0.9.11.jar:na]
at org.reflections.Reflections.scan(Reflections.java:253) ~[reflections-0.9.11.jar:na]
at org.apache.rocketmq.connect.runtime.utils.Plugin$PluginReflections.scan(Plugin.java:120) [classes/:na]
at org.reflections.Reflections$1.run(Reflections.java:198) [reflections-0.9.11.jar:na]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run(FutureTask.java) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_91]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
Caused by: org.reflections.ReflectionsException: could not create class file from pom.xml
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:102) ~[reflections-0.9.11.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:24) ~[reflections-0.9.11.jar:na]
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:30) ~[reflections-0.9.11.jar:na]
... 9 common frames omitted
Caused by: java.io.IOException: bad magic number: 3c70726f
at javassist.bytecode.ClassFile.read(ClassFile.java:825) ~[javassist-3.21.0-GA.jar:na]
at javassist.bytecode.ClassFile.<init>(ClassFile.java:154) ~[javassist-3.21.0-GA.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:100) ~[reflections-0.9.11.jar:na]
... 11 common frames omitted
11:08:53.021 [org.reflections-scanner-0] DEBUG org.reflections.Reflections - could not scan file META-INF/maven/org.slf4j/slf4j-api/pom.properties in url file:/home/zhuozl/rocketmq/connector-plugins/rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar with scanner SubTypesScanner
org.reflections.ReflectionsException: could not create class object from file META-INF/maven/org.slf4j/slf4j-api/pom.properties
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:32) ~[reflections-0.9.11.jar:na]
at org.reflections.Reflections.scan(Reflections.java:253) ~[reflections-0.9.11.jar:na]
at org.apache.rocketmq.connect.runtime.utils.Plugin$PluginReflections.scan(Plugin.java:120) [classes/:na]
at org.reflections.Reflections$1.run(Reflections.java:198) [reflections-0.9.11.jar:na]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run(FutureTask.java) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_91]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
Caused by: org.reflections.ReflectionsException: could not create class file from pom.properties
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:102) ~[reflections-0.9.11.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:24) ~[reflections-0.9.11.jar:na]
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:30) ~[reflections-0.9.11.jar:na]
... 9 common frames omitted
Caused by: java.io.IOException: bad magic number: 2347656e
at javassist.bytecode.ClassFile.read(ClassFile.java:825) ~[javassist-3.21.0-GA.jar:na]
at javassist.bytecode.ClassFile.<init>(ClassFile.java:154) ~[javassist-3.21.0-GA.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:100) ~[reflections-0.9.11.jar:na]
... 11 common frames omitted
11:08:53.029 [org.reflections-scanner-0] DEBUG org.reflections.Reflections - could not scan file ch/qos/logback/classic/boolex/EvaluatorTemplate.groovy in url file:/home/zhuozl/rocketmq/connector-plugins/rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar with scanner SubTypesScanner
org.reflections.ReflectionsException: could not create class object from file ch/qos/logback/classic/boolex/EvaluatorTemplate.groovy
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:32) ~[reflections-0.9.11.jar:na]
at org.reflections.Reflections.scan(Reflections.java:253) ~[reflections-0.9.11.jar:na]
at org.apache.rocketmq.connect.runtime.utils.Plugin$PluginReflections.scan(Plugin.java:120) [classes/:na]
at org.reflections.Reflections$1.run(Reflections.java:198) [reflections-0.9.11.jar:na]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run(FutureTask.java) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_91]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
Caused by: org.reflections.ReflectionsException: could not create class file from EvaluatorTemplate.groovy
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:102) ~[reflections-0.9.11.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:24) ~[reflections-0.9.11.jar:na]
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:30) ~[reflections-0.9.11.jar:na]
... 9 common frames omitted
Caused by: java.io.IOException: bad magic number: 2f2a2a0d
at javassist.bytecode.ClassFile.read(ClassFile.java:825) ~[javassist-3.21.0-GA.jar:na]
at javassist.bytecode.ClassFile.<init>(ClassFile.java:154) ~[javassist-3.21.0-GA.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:100) ~[reflections-0.9.11.jar:na]
... 11 common frames omitted
11:08:53.195 [org.reflections-scanner-0] DEBUG org.reflections.Reflections - could not scan file META-INF/maven/ch.qos.logback/logback-classic/pom.xml in url file:/home/zhuozl/rocketmq/connector-plugins/rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar with scanner SubTypesScanner
org.reflections.ReflectionsException: could not create class object from file META-INF/maven/ch.qos.logback/logback-classic/pom.xml
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:32) ~[reflections-0.9.11.jar:na]
at org.reflections.Reflections.scan(Reflections.java:253) ~[reflections-0.9.11.jar:na]
at org.apache.rocketmq.connect.runtime.utils.Plugin$PluginReflections.scan(Plugin.java:120) [classes/:na]
at org.reflections.Reflections$1.run(Reflections.java:198) [reflections-0.9.11.jar:na]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run(FutureTask.java) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_91]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
Caused by: org.reflections.ReflectionsException: could not create class file from pom.xml
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:102) ~[reflections-0.9.11.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:24) ~[reflections-0.9.11.jar:na]
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:30) ~[reflections-0.9.11.jar:na]
... 9 common frames omitted
Caused by: java.io.IOException: bad magic number: 3c70726f
at javassist.bytecode.ClassFile.read(ClassFile.java:825) ~[javassist-3.21.0-GA.jar:na]
at javassist.bytecode.ClassFile.<init>(ClassFile.java:154) ~[javassist-3.21.0-GA.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:100) ~[reflections-0.9.11.jar:na]
... 11 common frames omitted
11:08:53.218 [org.reflections-scanner-0] DEBUG org.reflections.Reflections - could not scan file META-INF/maven/ch.qos.logback/logback-classic/pom.properties in url file:/home/zhuozl/rocketmq/connector-plugins/rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar with scanner SubTypesScanner
org.reflections.ReflectionsException: could not create class object from file META-INF/maven/ch.qos.logback/logback-classic/pom.properties
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:32) ~[reflections-0.9.11.jar:na]
at org.reflections.Reflections.scan(Reflections.java:253) ~[reflections-0.9.11.jar:na]
at org.apache.rocketmq.connect.runtime.utils.Plugin$PluginReflections.scan(Plugin.java:120) [classes/:na]
at org.reflections.Reflections$1.run(Reflections.java:198) [reflections-0.9.11.jar:na]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run(FutureTask.java) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_91]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
Caused by: org.reflections.ReflectionsException: could not create class file from pom.properties
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:102) ~[reflections-0.9.11.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:24) ~[reflections-0.9.11.jar:na]
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:30) ~[reflections-0.9.11.jar:na]
... 9 common frames omitted
Caused by: java.io.IOException: bad magic number: 2347656e
at javassist.bytecode.ClassFile.read(ClassFile.java:825) ~[javassist-3.21.0-GA.jar:na]
at javassist.bytecode.ClassFile.<init>(ClassFile.java:154) ~[javassist-3.21.0-GA.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:100) ~[reflections-0.9.11.jar:na]
... 11 common frames omitted
11:08:53.543 [org.reflections-scanner-0] DEBUG org.reflections.Reflections - could not scan file META-INF/maven/ch.qos.logback/logback-core/pom.xml in url file:/home/zhuozl/rocketmq/connector-plugins/rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar with scanner SubTypesScanner
org.reflections.ReflectionsException: could not create class object from file META-INF/maven/ch.qos.logback/logback-core/pom.xml
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:32) ~[reflections-0.9.11.jar:na]
at org.reflections.Reflections.scan(Reflections.java:253) ~[reflections-0.9.11.jar:na]
at org.apache.rocketmq.connect.runtime.utils.Plugin$PluginReflections.scan(Plugin.java:120) [classes/:na]
at org.reflections.Reflections$1.run(Reflections.java:198) [reflections-0.9.11.jar:na]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run(FutureTask.java) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_91]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
Caused by: org.reflections.ReflectionsException: could not create class file from pom.xml
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:102) ~[reflections-0.9.11.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:24) ~[reflections-0.9.11.jar:na]
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:30) ~[reflections-0.9.11.jar:na]
... 9 common frames omitted
Caused by: java.io.IOException: bad magic number: 3c70726f
at javassist.bytecode.ClassFile.read(ClassFile.java:825) ~[javassist-3.21.0-GA.jar:na]
at javassist.bytecode.ClassFile.<init>(ClassFile.java:154) ~[javassist-3.21.0-GA.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:100) ~[reflections-0.9.11.jar:na]
... 11 common frames omitted
11:08:53.551 [org.reflections-scanner-0] DEBUG org.reflections.Reflections - could not scan file META-INF/maven/ch.qos.logback/logback-core/pom.properties in url file:/home/zhuozl/rocketmq/connector-plugins/rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar with scanner SubTypesScanner
org.reflections.ReflectionsException: could not create class object from file META-INF/maven/ch.qos.logback/logback-core/pom.properties
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:32) ~[reflections-0.9.11.jar:na]
at org.reflections.Reflections.scan(Reflections.java:253) ~[reflections-0.9.11.jar:na]
at org.apache.rocketmq.connect.runtime.utils.Plugin$PluginReflections.scan(Plugin.java:120) [classes/:na]
at org.reflections.Reflections$1.run(Reflections.java:198) [reflections-0.9.11.jar:na]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run(FutureTask.java) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_91]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
Caused by: org.reflections.ReflectionsException: could not create class file from pom.properties
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:102) ~[reflections-0.9.11.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:24) ~[reflections-0.9.11.jar:na]
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:30) ~[reflections-0.9.11.jar:na]
... 9 common frames omitted
Caused by: java.io.IOException: bad magic number: 2347656e
at javassist.bytecode.ClassFile.read(ClassFile.java:825) ~[javassist-3.21.0-GA.jar:na]
at javassist.bytecode.ClassFile.<init>(ClassFile.java:154) ~[javassist-3.21.0-GA.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:100) ~[reflections-0.9.11.jar:na]
... 11 common frames omitted
11:08:53.592 [org.reflections-scanner-0] DEBUG org.reflections.Reflections - could not scan file META-INF/DEPENDENCIES in url file:/home/zhuozl/rocketmq/connector-plugins/rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar with scanner SubTypesScanner
org.reflections.ReflectionsException: could not create class object from file META-INF/DEPENDENCIES
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:32) ~[reflections-0.9.11.jar:na]
at org.reflections.Reflections.scan(Reflections.java:253) ~[reflections-0.9.11.jar:na]
at org.apache.rocketmq.connect.runtime.utils.Plugin$PluginReflections.scan(Plugin.java:120) [classes/:na]
at org.reflections.Reflections$1.run(Reflections.java:198) [reflections-0.9.11.jar:na]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run(FutureTask.java) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_91]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
Caused by: org.reflections.ReflectionsException: could not create class file from DEPENDENCIES
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:102) ~[reflections-0.9.11.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:24) ~[reflections-0.9.11.jar:na]
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:30) ~[reflections-0.9.11.jar:na]
... 9 common frames omitted
Caused by: java.io.IOException: bad magic number: 2f2f202d
at javassist.bytecode.ClassFile.read(ClassFile.java:825) ~[javassist-3.21.0-GA.jar:na]
at javassist.bytecode.ClassFile.<init>(ClassFile.java:154) ~[javassist-3.21.0-GA.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:100) ~[reflections-0.9.11.jar:na]
... 11 common frames omitted
11:08:53.593 [org.reflections-scanner-0] DEBUG org.reflections.Reflections - could not scan file META-INF/NOTICE in url file:/home/zhuozl/rocketmq/connector-plugins/rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar with scanner SubTypesScanner
org.reflections.ReflectionsException: could not create class object from file META-INF/NOTICE
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:32) ~[reflections-0.9.11.jar:na]
at org.reflections.Reflections.scan(Reflections.java:253) ~[reflections-0.9.11.jar:na]
at org.apache.rocketmq.connect.runtime.utils.Plugin$PluginReflections.scan(Plugin.java:120) [classes/:na]
at org.reflections.Reflections$1.run(Reflections.java:198) [reflections-0.9.11.jar:na]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run(FutureTask.java) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_91]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
Caused by: org.reflections.ReflectionsException: could not create class file from NOTICE
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:102) ~[reflections-0.9.11.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:24) ~[reflections-0.9.11.jar:na]
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:30) ~[reflections-0.9.11.jar:na]
... 9 common frames omitted
Caused by: java.io.IOException: bad magic number: a726f63
at javassist.bytecode.ClassFile.read(ClassFile.java:825) ~[javassist-3.21.0-GA.jar:na]
at javassist.bytecode.ClassFile.<init>(ClassFile.java:154) ~[javassist-3.21.0-GA.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:100) ~[reflections-0.9.11.jar:na]
... 11 common frames omitted
11:08:53.687 [org.reflections-scanner-0] DEBUG org.reflections.Reflections - could not scan file META-INF/maven/org.apache.rocketmq/rocketmq-client/pom.xml in url file:/home/zhuozl/rocketmq/connector-plugins/rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar with scanner SubTypesScanner
org.reflections.ReflectionsException: could not create class object from file META-INF/maven/org.apache.rocketmq/rocketmq-client/pom.xml
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:32) ~[reflections-0.9.11.jar:na]
at org.reflections.Reflections.scan(Reflections.java:253) ~[reflections-0.9.11.jar:na]
at org.apache.rocketmq.connect.runtime.utils.Plugin$PluginReflections.scan(Plugin.java:120) [classes/:na]
at org.reflections.Reflections$1.run(Reflections.java:198) [reflections-0.9.11.jar:na]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run(FutureTask.java) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_91]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
Caused by: org.reflections.ReflectionsException: could not create class file from pom.xml
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:102) ~[reflections-0.9.11.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:24) ~[reflections-0.9.11.jar:na]
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:30) ~[reflections-0.9.11.jar:na]
... 9 common frames omitted
Caused by: java.io.IOException: bad magic number: 3c212d2d
at javassist.bytecode.ClassFile.read(ClassFile.java:825) ~[javassist-3.21.0-GA.jar:na]
at javassist.bytecode.ClassFile.<init>(ClassFile.java:154) ~[javassist-3.21.0-GA.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:100) ~[reflections-0.9.11.jar:na]
... 11 common frames omitted
11:08:53.720 [org.reflections-scanner-0] DEBUG org.reflections.Reflections - could not scan file META-INF/LICENSE in url file:/home/zhuozl/rocketmq/connector-plugins/rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar with scanner SubTypesScanner
org.reflections.ReflectionsException: could not create class object from file META-INF/LICENSE
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:32) ~[reflections-0.9.11.jar:na]
at org.reflections.Reflections.scan(Reflections.java:253) ~[reflections-0.9.11.jar:na]
at org.apache.rocketmq.connect.runtime.utils.Plugin$PluginReflections.scan(Plugin.java:120) [classes/:na]
at org.reflections.Reflections$1.run(Reflections.java:198) [reflections-0.9.11.jar:na]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run(FutureTask.java) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_91]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
Caused by: org.reflections.ReflectionsException: could not create class file from LICENSE
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:102) ~[reflections-0.9.11.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:24) ~[reflections-0.9.11.jar:na]
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:30) ~[reflections-0.9.11.jar:na]
... 9 common frames omitted
Caused by: java.io.IOException: bad magic number: a202020
at javassist.bytecode.ClassFile.read(ClassFile.java:825) ~[javassist-3.21.0-GA.jar:na]
at javassist.bytecode.ClassFile.<init>(ClassFile.java:154) ~[javassist-3.21.0-GA.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:100) ~[reflections-0.9.11.jar:na]
... 11 common frames omitted
11:08:53.721 [org.reflections-scanner-0] DEBUG org.reflections.Reflections - could not scan file META-INF/maven/org.apache.rocketmq/rocketmq-client/pom.properties in url file:/home/zhuozl/rocketmq/connector-plugins/rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar with scanner SubTypesScanner
org.reflections.ReflectionsException: could not create class object from file META-INF/maven/org.apache.rocketmq/rocketmq-client/pom.properties
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:32) ~[reflections-0.9.11.jar:na]
at org.reflections.Reflections.scan(Reflections.java:253) ~[reflections-0.9.11.jar:na]
at org.apache.rocketmq.connect.runtime.utils.Plugin$PluginReflections.scan(Plugin.java:120) [classes/:na]
at org.reflections.Reflections$1.run(Reflections.java:198) [reflections-0.9.11.jar:na]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run(FutureTask.java) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_91]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
Caused by: org.reflections.ReflectionsException: could not create class file from pom.properties
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:102) ~[reflections-0.9.11.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:24) ~[reflections-0.9.11.jar:na]
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:30) ~[reflections-0.9.11.jar:na]
... 9 common frames omitted
Caused by: java.io.IOException: bad magic number: 23437265
at javassist.bytecode.ClassFile.read(ClassFile.java:825) ~[javassist-3.21.0-GA.jar:na]
at javassist.bytecode.ClassFile.<init>(ClassFile.java:154) ~[javassist-3.21.0-GA.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:100) ~[reflections-0.9.11.jar:na]
... 11 common frames omitted
```
--
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
[GitHub] [rocketmq-externals] zhuozl edited a comment on issue #804: rocketmq-replicator
Posted by GitBox <gi...@apache.org>.
zhuozl edited a comment on issue #804:
URL: https://github.com/apache/rocketmq-externals/issues/804#issuecomment-909865714
sh run_worker.sh
```
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
```
--
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
[GitHub] [rocketmq-externals] zhuozl commented on issue #804: rocketmq-replicator
Posted by GitBox <gi...@apache.org>.
zhuozl commented on issue #804:
URL: https://github.com/apache/rocketmq-externals/issues/804#issuecomment-909865714
sh run_worker.sh
```
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
```
--
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
[GitHub] [rocketmq-externals] zhuozl commented on issue #804: rocketmq-replicator
Posted by GitBox <gi...@apache.org>.
zhuozl commented on issue #804:
URL: https://github.com/apache/rocketmq-externals/issues/804#issuecomment-909836394
@lizhiboo rocketmq cluster is works.
有本地,调试文档吗? 本地idea部署会报如下错误
```
11:08:52.640 [org.reflections-scanner-0] DEBUG org.reflections.Reflections - [Thread[org.reflections-scanner-0,5,main]] scanning file:/home/zhuozl/rocketmq/connector-plugins/rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar
11:08:52.831 [org.reflections-scanner-0] DEBUG org.reflections.Reflections - could not scan file META-INF/MANIFEST.MF in url file:/home/zhuozl/rocketmq/connector-plugins/rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar with scanner SubTypesScanner
org.reflections.ReflectionsException: could not create class object from file META-INF/MANIFEST.MF
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:32) ~[reflections-0.9.11.jar:na]
at org.reflections.Reflections.scan(Reflections.java:253) ~[reflections-0.9.11.jar:na]
at org.apache.rocketmq.connect.runtime.utils.Plugin$PluginReflections.scan(Plugin.java:120) [classes/:na]
at org.reflections.Reflections$1.run(Reflections.java:198) [reflections-0.9.11.jar:na]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run(FutureTask.java) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_91]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
Caused by: org.reflections.ReflectionsException: could not create class file from MANIFEST.MF
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:102) ~[reflections-0.9.11.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:24) ~[reflections-0.9.11.jar:na]
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:30) ~[reflections-0.9.11.jar:na]
... 9 common frames omitted
Caused by: java.io.IOException: bad magic number: 4d616e69
at javassist.bytecode.ClassFile.read(ClassFile.java:825) ~[javassist-3.21.0-GA.jar:na]
at javassist.bytecode.ClassFile.<init>(ClassFile.java:154) ~[javassist-3.21.0-GA.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:100) ~[reflections-0.9.11.jar:na]
... 11 common frames omitted
11:08:53.019 [org.reflections-scanner-0] DEBUG org.reflections.Reflections - could not scan file META-INF/maven/org.slf4j/slf4j-api/pom.xml in url file:/home/zhuozl/rocketmq/connector-plugins/rocketmq-replicator-0.1.0-SNAPSHOT-jar-with-dependencies.jar with scanner SubTypesScanner
org.reflections.ReflectionsException: could not create class object from file META-INF/maven/org.slf4j/slf4j-api/pom.xml
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:32) ~[reflections-0.9.11.jar:na]
at org.reflections.Reflections.scan(Reflections.java:253) ~[reflections-0.9.11.jar:na]
at org.apache.rocketmq.connect.runtime.utils.Plugin$PluginReflections.scan(Plugin.java:120) [classes/:na]
at org.reflections.Reflections$1.run(Reflections.java:198) [reflections-0.9.11.jar:na]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) [na:1.8.0_91]
at java.util.concurrent.FutureTask.run(FutureTask.java) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_91]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]
Caused by: org.reflections.ReflectionsException: could not create class file from pom.xml
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:102) ~[reflections-0.9.11.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:24) ~[reflections-0.9.11.jar:na]
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:30) ~[reflections-0.9.11.jar:na]
... 9 common frames omitted
Caused by: java.io.IOException: bad magic number: 3c70726f
at javassist.bytecode.ClassFile.read(ClassFile.java:825) ~[javassist-3.21.0-GA.jar:na]
at javassist.bytecode.ClassFile.<init>(ClassFile.java:154) ~[javassist-3.21.0-GA.jar:na]
at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:100) ~[reflections-0.9.11.jar:na]
... 11 common frames omitted
```
--
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
[GitHub] [rocketmq-externals] zhuozl commented on issue #804: rocketmq-replicator
Posted by GitBox <gi...@apache.org>.
zhuozl commented on issue #804:
URL: https://github.com/apache/rocketmq-externals/issues/804#issuecomment-909836394
--
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
[GitHub] [rocketmq-externals] zhuozl edited a comment on issue #804: rocketmq-replicator
Posted by GitBox <gi...@apache.org>.
zhuozl edited a comment on issue #804:
URL: https://github.com/apache/rocketmq-externals/issues/804#issuecomment-909865714
--
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
[GitHub] [rocketmq-externals] zhuozl removed a comment on issue #804: rocketmq-replicator
Posted by GitBox <gi...@apache.org>.
zhuozl removed a comment on issue #804:
URL: https://github.com/apache/rocketmq-externals/issues/804#issuecomment-909865714
sh run_worker.sh topic 复到别外一个集群了. 往源集群topic 发送消息, 目标集群topic 没有收到消息
```
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
```
--
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
[GitHub] [rocketmq-externals] zhuozl commented on issue #804: rocketmq-replicator
Posted by GitBox <gi...@apache.org>.
zhuozl commented on issue #804:
URL: https://github.com/apache/rocketmq-externals/issues/804#issuecomment-911104591
@lizhiboo connect.conf 的namesrvAddr 要配置为目的的namesrvAddr可以了.不过会丢失 tag,key
--
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
[GitHub] [rocketmq-externals] zhuozl edited a comment on issue #804: rocketmq-replicator
Posted by GitBox <gi...@apache.org>.
zhuozl edited a comment on issue #804:
URL: https://github.com/apache/rocketmq-externals/issues/804#issuecomment-909865714
sh run_worker.sh topic 复到别外一个集群了. 往源集群topic 发送消息, 目标集群topic 没有收到消息
```
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not started.
```
--
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
[GitHub] [rocketmq-externals] lizhiboo commented on issue #804: rocketmq-replicator
Posted by GitBox <gi...@apache.org>.
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
[GitHub] [rocketmq-externals] lizhiboo commented on issue #804: rocketmq-replicator
Posted by GitBox <gi...@apache.org>.
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