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

Thomas Weise closed APEXMALHAR-1947.
------------------------------------
       Resolution: Fixed
    Fix Version/s: 3.3.0

> Ability to restrict number of messages per window by size for kafka input 
> operator
> ----------------------------------------------------------------------------------
>
>                 Key: APEXMALHAR-1947
>                 URL: https://issues.apache.org/jira/browse/APEXMALHAR-1947
>             Project: Apache Apex Malhar
>          Issue Type: Bug
>            Reporter: Pramod Immaneni
>            Assignee: Pramod Immaneni
>             Fix For: 3.3.0
>
>
> Currently the kafka input operators support a setting to restrict number of 
> tuples per window for throttling the input in case downstream operators 
> cannot handle the input bursts. In certain application scenarios the kafka 
> message sizes are not similar and could vary significantly from small to 
> large. In those case a setting based on message sizes is more appropriate 
> like a maximum total message size per window.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to