[ https://issues.apache.org/jira/browse/IGNITE-533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15879771#comment-15879771 ]
Denis Magda commented on IGNITE-533: ------------------------------------ [~dreamx], have you added the new test suite to TeamCity? We need to be sure that the test suite passes there as well. Could you create a documentation for the streamer as well? I've created a hidden page and granted you editor's rights, check up your email: https://apacheignite-mix.readme.io/docs/zeromq-streamer You can refer to the documentations prepared for the other streamers to form an understanding on how ZeroMQ doc should look like. https://apacheignite-mix.readme.io/docs/mqtt-streamer https://apacheignite-mix.readme.io/docs/storm-streamer https://apacheignite-mix.readme.io/docs/flink-streamer > Implement IgniteZeromqStreamer to stream data from ZeroMQ > --------------------------------------------------------- > > Key: IGNITE-533 > URL: https://issues.apache.org/jira/browse/IGNITE-533 > Project: Ignite > Issue Type: Sub-task > Components: streaming > Reporter: Dmitriy Setrakyan > Assignee: Maksim Kozlov > Fix For: 2.0 > > > We have {{IgniteDataStreamer}} which is used to load data into Ignite under > high load. It was previously named {{IgniteDataLoader}}, see ticket > IGNITE-394. > See [ZeroMQ|http://zeromq.org/] for more info. > We should create {{IgniteZeroMqStreamer}} which will consume messages from > Twitter and stream them into Ignite caches. > More details to follow, but to the least we should be able to: > * Convert ZeroMQ messages to Ignite data using an optional pluggable > converter. If not provided, we should have some default mechanism. > * Specify the cache name for the Ignite cache to load data into. > * Specify other flags available on {{IgniteDataStreamer}} class. -- This message was sent by Atlassian JIRA (v6.3.15#6346)