implementing new method at PassthoughMapper
@@ -73,4 +73,8 @@ public class PassThroughSourceMapper extends SourceMapper {
}
}
}
+
+ @Override protected boolean allowNullInTransportProperties() {
+ return false;
+ }
}
