diff --git a/sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/DebeziumIO.java b/sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/DebeziumIO.java index be418aed5cab..b38c035adf2d 100644 --- a/sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/DebeziumIO.java +++ b/sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/DebeziumIO.java @@ -63,6 +63,11 @@ * *
Support is currently experimental. One of the known issues is that the connector does not + * preserve the offset on a worker crash or restart, causing it to retrieve all the data from the + * beginning again. See Issue #28248 for + * details. + * *
Connect to a Debezium - MySQL database and run a Pipeline * *