[ https://issues.apache.org/jira/browse/BEAM-3819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Alexey Romanenko reassigned BEAM-3819: -------------------------------------- Assignee: Alexey Romanenko (was: Jean-Baptiste Onofré) > Add withLimit() option to KinesisIO > ----------------------------------- > > Key: BEAM-3819 > URL: https://issues.apache.org/jira/browse/BEAM-3819 > Project: Beam > Issue Type: Improvement > Components: io-java-kinesis > Reporter: Jean-Baptiste Onofré > Assignee: Alexey Romanenko > Priority: Major > Time Spent: 20m > Remaining Estimate: 0h > > In some cases, the user might need to set the {{limit}} on the > {{SimplifiedKinesisClient}}, especially for performance reason, depending of > the number of records. -- This message was sent by Atlassian JIRA (v7.6.3#76005)