Re: Count Incoming Unbounded records using Apache Beam java

Hi, thanks for your interest in Apache Beam. I answered your question, see [1] Best,  Jan [1] https://stackoverflow.com/questions/76681800/count-incoming-unbouned-messages-from-pubsub-using-apache-beam-java/76685799#76685799 On 7/13/23 19:17, Phani Geeth wrote: Hi, I am trying to count the

Disaster recovery in dataflow with kafka connector

Hello, I'm trying to identify what is the workaround given different error scenarios when I'm reading from kafka in apache beam on google dataflow. 1) from [1] it says "Dataflow also does have in-place pipeline update that restores the persisted checkpoints from one pipeline to another" --> that m

Re: Getting Started With Implementing a Runner

I'm taking an action item to update that page, as it is *way* out of date. On Thu, Jul 13, 2023 at 6:54 PM Joey Tran wrote: > I see. I guess I got a little confused since these are mentioned in the > Authoring > a Runner >