[ 
https://issues.apache.org/jira/browse/STORM-1695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Hugo Louro resolved STORM-1695.
-------------------------------
    Resolution: Fixed

Merged onto master:

https://github.com/apache/storm/pull/1687
https://github.com/apache/storm/pull/1757
https://github.com/apache/storm/pull/1779

> Create trident spout that uses the new kafka consumer API
> ---------------------------------------------------------
>
>                 Key: STORM-1695
>                 URL: https://issues.apache.org/jira/browse/STORM-1695
>             Project: Apache Storm
>          Issue Type: Improvement
>          Components: storm-kafka
>            Reporter: Thomas Graves
>            Assignee: Hugo Louro
>
> In storm-822 we added a new kafka spout 
> (org.apache.storm.kafka.spout.KafkaSpout) that uses the new consumer Api in 
> Kafka 0.9.  We decided in that one to handle the Trident support separately.  
> So this jira is to add Trident support for it similar to what 
> OpaqueTridentKafkaSpout does for the kafka old consumer api.  We need to 
> support the new consumer api to allow access to a secure Kafka cluster which 
> was added in Kafka 0.9.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to