Stig Rohde Døssing created STORM-3399:
-----------------------------------------
Summary: Add ability to set priority among partitions in KafkaSpout
Key: STORM-3399
URL: https://issues.apache.org/jira/browse/STORM-3399
Project: Apache Storm
Issue Type: New Feature
Components: storm-kafka-client
Reporter: Stig Rohde Døssing
This idea was raised for the old storm-kafka spout at
https://issues.apache.org/jira/browse/STORM-3160. As I'm closing that issue,
I'm raising this one to implement that functionality in the new spout.
I believe doing this should be possible using KafkaConsumer.pause and
KafkaConsumer.resume.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
