Techniques for building predictable stream processing pipelines