Acknowledgements
Acknowledgements are sent to input data_source with respect to output data_source. In order to implement it output data source is encoded by numbers and used as group_id by acknowledgement.
Before starting worker choose an input stream for a given data_source, that contains non-acknowledged messages.
Edited by Mikhail Karnevskiy