Root cause
The connector is configured with snapshot.mode=custom but the snapshot.mode.custom.name property is missing. This property must hold the name returned by the Snapshotter.name() method of your implementation (discovered via Java ServiceLoader, not a class name lookup).
How to fix
- Set snapshot.mode.custom.name to the value returned by your Snapshotter.name() method.
- Register your implementation via ServiceLoader: add META-INF/services/io.debezium.spi.snapshot.Snapshotter containing your class name in the JAR.
- Ensure the JAR is on the Kafka Connect plugin path (connector plugins directory).
Official Debezium documentation ↗