what I can think of is
1. put trigger processing time some interval rather than continuos.The Api hit of checkpoint storage increase cost,not dbus but for cloud vendor
2.If you have multiple streams then multiplex multiple streams into one,rather than different cluster for different streams.
