This is an automated email from the ASF dual-hosted git repository.
MartijnVisser pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git
The following commit(s) were added to refs/heads/main by this push:
new 2c2a7170 [hotfix][javadocs] Fix KafkaSink recovery test link
2c2a7170 is described below
commit 2c2a7170c88d111a1e63fcfe6af1a0844d1ecc81
Author: Aleksandr Savonin <[email protected]>
AuthorDate: Sat Sep 19 22:16:03 2026 +0200
[hotfix][javadocs] Fix KafkaSink recovery test link
Generated-by: Codex (GPT-6)
---
.../flink/connector/kafka/sink/KafkaSinkRecoveryITCase.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git
a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkRecoveryITCase.java
b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkRecoveryITCase.java
index 6e86ff56..689608f1 100644
---
a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkRecoveryITCase.java
+++
b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkRecoveryITCase.java
@@ -102,11 +102,11 @@ import static org.assertj.core.api.Assertions.assertThat;
* transactional id, while C1 remains the latest completed checkpoint. The job
is then cancelled and
* restored from C1 with the same transactional id prefix and operator
identities.
*
- * <p>This exercises the recovery fencing scenario described in {@link
- * KafkaCommitter#logFencedRequest}. The restored job must replay the
uncheckpointed records and
- * successfully commit new transactions without losing or duplicating records.
The first checkpoint
- * after restoration must make the replayed record visible to {@code
read_committed} consumers; an
- * abandoned transaction under the reused transactional id must not block that
output.
+ * <p>This exercises the recovery fencing scenario handled by {@link
KafkaCommitter#commit}. The
+ * restored job must replay the uncheckpointed records and successfully commit
new transactions
+ * without losing or duplicating records. The first checkpoint after
restoration must make the
+ * replayed record visible to {@code read_committed} consumers; an abandoned
transaction under the
+ * reused transactional id must not block that output.
*/
@Testcontainers
class KafkaSinkRecoveryITCase {
