[ https://issues.apache.org/jira/browse/STORM-3399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16920607#comment-16920607 ]
Rishabh Jain commented on STORM-3399: ------------------------------------- [~Srdo] I would like to take this up. Please let me know. > 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 > Priority: Minor > Labels: newbie > > 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 (v8.3.2#803003)