Merge pull request #14705: [BEAM-11754] Update docs about EOS support
diff --git a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java
index 29d8bac..499a1f8 100644
--- a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java
+++ b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java
@@ -2197,10 +2197,8 @@
* transform ties checkpointing semantics in compatible Beam runners and transactions in Kafka
* (version 0.11+) to ensure a record is written only once. As the implementation relies on
* runners checkpoint semantics, not all the runners are compatible. The sink throws an
- * exception during initialization if the runner is not explicitly allowed. Flink runner is one
- * of the runners whose checkpoint semantics are not compatible with current implementation
- * (hope to provide a solution in near future). Dataflow runner and Spark runners are
- * compatible.
+ * exception during initialization if the runner is not explicitly allowed. The Dataflow, Flink,
+ * and Spark runners are compatible.
*
* <p>Note on performance: Exactly-once sink involves two shuffles of the records. In addition
* to cost of shuffling the records among workers, the records go through 2
