This change moves the source table inspection previously performed in the source task to the source connector so that the tasks can be created correctly and distributed to the available number of workers.
It resolves one of the problems reported by #89, namely using a tasks.max > 1 creating multiple tasks pulling the same set of data, thereby generating duplicates.
This change moves the source table inspection previously performed in the source task to the source connector so that the tasks can be created correctly and distributed to the available number of workers.
It resolves one of the problems reported by #89, namely using a tasks.max > 1 creating multiple tasks pulling the same set of data, thereby generating duplicates.