This is an automated email from the ASF dual-hosted git repository.
yhu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new f9bccb8d36f Warn against DebeziumIO not resilient to worker crash or
restart (#37076)
f9bccb8d36f is described below
commit f9bccb8d36fa135fc3b8caed80de9806e94ad394
Author: Yi Hu <[email protected]>
AuthorDate: Fri Dec 12 12:21:35 2025 -0500
Warn against DebeziumIO not resilient to worker crash or restart (#37076)
---
.../src/main/java/org/apache/beam/io/debezium/DebeziumIO.java | 5 +++++
1 file changed, 5 insertions(+)
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 be418aed5ca..b38c035adf2 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 @@ import org.slf4j.LoggerFactory;
*
* <h3>Usage example</h3>
*
+ * <p>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 <a
href="https://github.com/apache/beam/issues/28248";>Issue #28248</a> for
+ * details.
+ *
* <p>Connect to a Debezium - MySQL database and run a Pipeline
*
* <pre>
