[jira] [Updated] (BEAM-6333) allow disabling/configuring automatic watermark generation for idle kafka partitions

["Alexey Romanenko (JIRA)" <ji...@apache.org>]

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

Alexey Romanenko updated BEAM-6333:
-----------------------------------
    Fix Version/s:     (was: 2.9.1)

> allow disabling/configuring automatic watermark generation for idle kafka partitions
> ------------------------------------------------------------------------------------
>
>                 Key: BEAM-6333
>                 URL: https://issues.apache.org/jira/browse/BEAM-6333
>             Project: Beam
>          Issue Type: Improvement
>          Components: io-java-kafka
>    Affects Versions: 2.9.0
>            Reporter: Jan Doms
>            Assignee: Raghu Angadi
>            Priority: Major
>              Labels: easyfix, pull-request-available
>   Original Estimate: 0.5h
>  Remaining Estimate: 0.5h
>
> For pipelines that require the emitted watermarks to be absolutely correct the current behavior using 2 seconds timeout could lead to problems.
> Therefor it should be possible to disable this behavior. While changing the code the hardcoded 2 seconds can also be made configurable. (There's already a TODO about that in the code.)
>  
> A (preliminary) PR making this change is available: https://github.com/apache/beam/pull/7382.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)