Warn against DebeziumIO not resilient to worker crash or restart (#37076)

Abacn · web-flow · commit f9bccb8d36fa · 2025-12-12T12:21:35.000-05:00
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
@@ -63,6 +63,11 @@
  *
  * <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>

Original file line number	Diff line number	Diff line change
`@@ -63,6 +63,11 @@`
`63`	`63`	`*`
`64`	`64`	`* <h3>Usage example</h3>`
`65`	`65`	`*`
	`66`	`+ * <p>Support is currently experimental. One of the known issues is that the connector does not`
	`67`	`+ * preserve the offset on a worker crash or restart, causing it to retrieve all the data from the`
	`68`	`+ * beginning again. See <a href="https://github.com/apache/beam/issues/28248">Issue #28248</a> for`
	`69`	`+ * details.`
	`70`	`+ *`
`66`	`71`	`* <p>Connect to a Debezium - MySQL database and run a Pipeline`
`67`	`72`	`*`
`68`	`73`	`* <pre>`