A technique includes comparing a first sequence of tasks of a first data processing pipeline of a plurality of data processing pipelines for a data streaming system to a second data processing pipeline of the plurality of data processing pipelines. The technique includes, based on the comparing, combining the first data processing pipeline and the second data processing pipeline into a single data processing pipeline.