Skip to content

Acknowledgements

Tim Schoof requested to merge acknowledgements into master

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

Merge request reports