You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@storm.apache.org by "Jungtaek Lim (JIRA)" <ji...@apache.org> on 2017/08/24 05:55:00 UTC

[jira] [Updated] (STORM-1695) Create trident spout that uses the new kafka consumer API

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

Jungtaek Lim updated STORM-1695:
--------------------------------
    Fix Version/s: 1.1.0
                   2.0.0

> 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
>             Fix For: 2.0.0, 1.1.0
>
>
> 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.4.14#64029)