[ https://issues.apache.org/jira/browse/IGNITE-535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sergey Kozlov closed IGNITE-535. -------------------------------- Assignee: Sergey Kozlov (was: Raúl Kripalani) > Implement IgniteMqttStreamer to stream data from MQTT > ----------------------------------------------------- > > Key: IGNITE-535 > URL: https://issues.apache.org/jira/browse/IGNITE-535 > Project: Ignite > Issue Type: Sub-task > Components: streaming > Reporter: Dmitriy Setrakyan > Assignee: Sergey Kozlov > Fix For: 1.5 > > > We have {{IgniteDataStreamer}} which is used to load data into Ignite under > high load. It was previously named {{IgniteDataLoader}}, see ticket > IGNITE-394. > See [MQTT|http://mqtt.org/] site for more info. > We should create {{IgniteMqttStreamer}} 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 MQTT 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.4#6332)