Debezium based replicator app sources (mysql and sql server) generates ordered events to be processed by downstream targets. However there is possibility that some replicator sources may not provide such guarantee.
In case of such sources, replicator app needs a way to know that source is generating un-ordered events so that it can convey that information to the targets which then can take appropriate actions.
Proposal for new Configurer API for the replicator source:
where RowIDKey is simple POJO as follows:
Configure method of DeltaSource now can be updated to take the new source configurer
This source information will be available to the targets in the replicator app through context as
where SourceDetails would be
It is better to have setOrdering(Ordering ordering) with Ordering as an enum.