Beam slowness compared to flink-native

Hi, I’m investigating a slowness of our beam pipelines, and as part of that I tried to compare a very simple beam pipeline with an equivalent flink-native pipeline. Both pipelines should read strings from one kafka topic and write them to another topic. I’m using beam 2.38.0 and flink 1.13. I t

Scio 0.11.6 released

Hi all, We just released Scio 0.11.6 . This bumps Beam SDK to 2.38.0 and includes some improvements & bug fixes. Cheers, *v0.11.6 "Colchis"* [image: rocket] Enhancements - Add scio-elasticsearc