Add batch support for consuming messages from pipeline.