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