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

Reply via email to