Re: flink version stable

2024-03-30 Thread Lincoln Lee
Hi Thierry, The flink connectors have been separated from the main flink repository[1], using separate repositories and release process[2]. For example, https://github.com/apache/flink-connector-kafka for the Kafka connector, and its latest release is v3.1.0[3]. You can follow new releases of spec

Flink pipeline throughput

2024-03-30 Thread Kartik Kushwaha
Hello, I have a Streaming event processing job that looks like this. *Source - ProcessFn(3 in total) - Sink* I am seeing a delay of 50ms to 250ms between each operators (maybe buffering or serde delays) leading to a slow end- to-end processing. What could be the reason for such high latency? So