The MigratoryData Source Connector for Kafka consumes MigratoryData messages from a configurable list of topics and streams them to Kafka according to a configurable mapping between MigratoryData subjects and Kafka topics.

Reliable with no message loss

MigratoryData Source Connector achieves reliable messaging without message losses. Indeed, each task of the MigratoryData Source Connector writes into Kafka the sequence numbers of the MigratoryData messages successfully published into Kafka. Therefore, if a task is restarted after a failure or a load re-balance performed by Kafka Connect, the task will continue publication from the last sequence numbers previously acknowledged by the task.