[
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)