yelianevich commented on issue #31085: URL: https://github.com/apache/beam/issues/31085#issuecomment-2115439116
Thanks, I'll create a separate issue. What do you think about the issue with KafkaIO? The topic has 3 partitions. As you can see from the screenshot below it received just one record in one of the partitions. A watermark was not propagated in this case further. I've tryied to set --autoWatermarkInterval=100, but it did not have any effect. There are no other Beam-specific properties set.  -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
