[JIRA] (MLHR-1947) Ability to restrict number of messages per window by size for kafka input operator

0 views
Skip to first unread message

Pramod Immaneni (JIRA)

unread,
Dec 15, 2015, 7:45:03 AM12/15/15
to malhar...@googlegroups.com
Pramod Immaneni created an issue
 
Malhar / Bug MLHR-1947
Ability to restrict number of messages per window by size for kafka input operator
Issue Type: Bug Bug
Assignee: Pramod Immaneni
Created: 15/Dec/15 4:44 AM
Priority: Major Major
Reporter: Pramod Immaneni

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.

Add Comment Add Comment
 
This message was sent by Atlassian JIRA (v7.1.0-OD-02-030#71001-sha1:2ba8c0f)
Atlassian logo
Reply all
Reply to author
Forward
0 new messages