You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@storm.apache.org by "Stig Rohde Døssing (JIRA)" <ji...@apache.org> on 2019/06/01 09:05:00 UTC

[jira] [Updated] (STORM-3399) Add ability to set priority among partitions in KafkaSpout

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

Stig Rohde Døssing updated STORM-3399:
--------------------------------------
    Labels: newbie  (was: )

> 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
(v7.6.3#76005)