Hello, I am using Samza runner with Apache Beam. Is there any documentation available on how bundles are implemented in the Samza runner? I have observed every Kafka record getting processed in its own bundle. How can I get larger bundles?
<beam.version>2.9.0 <samza.version>0.14.1 Thanks, Omkar