diff --git a/debezium-core/src/main/java/io/debezium/connector/SnapshotRecord.java b/debezium-core/src/main/java/io/debezium/connector/SnapshotRecord.java index 1ba2bbd96..44c0eb824 100644 --- a/debezium-core/src/main/java/io/debezium/connector/SnapshotRecord.java +++ b/debezium-core/src/main/java/io/debezium/connector/SnapshotRecord.java @@ -14,9 +14,18 @@ * */ public enum SnapshotRecord { - TRUE, // record is from snapshot is not the last one - FALSE, // record is from snapshot is the last record generated in snapshot phase - LAST; // record is from streaming phase + /** + * Record is from snapshot is not the last one. + */ + TRUE, + /** + * Record is from snapshot is the last record generated in snapshot phase. + */ + LAST, + /** + * Record is from streaming phase. + */ + FALSE; public static SnapshotRecord fromSource(Struct source) { if (source.schema().field(AbstractSourceInfo.SNAPSHOT_KEY) != null && io.debezium.data.Enum.LOGICAL_NAME.equals(source.schema().field(AbstractSourceInfo.SNAPSHOT_KEY).schema().name())) {