ignite-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Alexey Goncharuk (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (IGNITE-4539) RocketMQ data streamer
Date Tue, 18 Apr 2017 13:06:42 GMT

    [ 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)

Mime
View raw message