Uploaded image for project: 'Apache Storm'
  1. Apache Storm
  2. STORM-1695

Create trident spout that uses the new kafka consumer API

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 2.0.0, 1.1.0
    • Component/s: storm-kafka
    • Labels:
      None

      Description

      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.

        Attachments

          Activity

            People

            • Assignee:
              hmclouro Hugo Da Cruz Louro
              Reporter:
              tgraves Thomas Graves
            • Votes:
              2 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: