[
https://issues.apache.org/jira/browse/IGNITE-4539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15972629#comment-15972629
]
Alexey Goncharuk commented on IGNITE-4539:
------------------------------------------
Hi Roman,
I tried to run the unit-test you provided, but it fails with the following
exception:
{code}
org.apache.rocketmq.client.exception.MQClientException: create new topic failed
For more information, please visit the url, http://rocketmq.apache.org/docs/faq/
at
org.apache.rocketmq.client.impl.MQAdminImpl.createTopic(MQAdminImpl.java:129)
at
org.apache.rocketmq.tools.admin.DefaultMQAdminExtImpl.createTopic(DefaultMQAdminExtImpl.java:897)
at
org.apache.rocketmq.tools.admin.DefaultMQAdminExt.createTopic(DefaultMQAdminExt.java:97)
at
org.apache.rocketmq.tools.admin.DefaultMQAdminExt.createTopic(DefaultMQAdminExt.java:92)
at org.apache.rocketmq.test.util.MQAdmin.createTopic(MQAdmin.java:46)
at
org.apache.ignite.stream.rocketmq.RocketMQStreamerTest$2.apply(RocketMQStreamerTest.java:203)
at
org.apache.ignite.testframework.GridTestUtils.waitForCondition(GridTestUtils.java:1600)
at
org.apache.ignite.stream.rocketmq.RocketMQStreamerTest.initTopic(RocketMQStreamerTest.java:201)
at
org.apache.ignite.stream.rocketmq.RocketMQStreamerTest.produceData(RocketMQStreamerTest.java:171)
at
org.apache.ignite.stream.rocketmq.RocketMQStreamerTest.testStreamer(RocketMQStreamerTest.java:137)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at junit.framework.TestCase.runTest(TestCase.java:176)
at
org.apache.ignite.testframework.junits.GridAbstractTest.runTestInternal(GridAbstractTest.java:1928)
at
org.apache.ignite.testframework.junits.GridAbstractTest.access$000(GridAbstractTest.java:125)
at
org.apache.ignite.testframework.junits.GridAbstractTest$5.run(GridAbstractTest.java:1843)
at java.lang.Thread.run(Thread.java:745)
Caused by: org.apache.rocketmq.client.exception.MQClientException: CODE: 17
DESC: No topic route info in name server for the topic: testCluster
See http://rocketmq.apache.org/docs/faq/ for further details.
at
org.apache.rocketmq.client.impl.MQClientAPIImpl.getTopicRouteInfoFromNameServer(MQClientAPIImpl.java:1212)
at
org.apache.rocketmq.client.impl.MQAdminImpl.createTopic(MQAdminImpl.java:81)
... 18 more
{code}
Can you take a look?
> RocketMQ data streamer
> ----------------------
>
> Key: IGNITE-4539
> URL: https://issues.apache.org/jira/browse/IGNITE-4539
> Project: Ignite
> Issue Type: New Feature
> Components: streaming
> Reporter: Roman Shtykh
> Assignee: Roman Shtykh
> Labels: important
> Fix For: 2.0
>
>
> Streamer for RocketMQ (https://github.com/rocketmq)
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
