[flink-connector-kafka] 21/27: [FLINK-30755][connector] Support getting attempt number from Sink context

[martijnvisser]

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

commit cf0648412f9631d76676cf61c028719c16fc5602
Author: ifndef-SleePy <mmyy1...@gmail.com>
AuthorDate: Sun Jan 22 23:26:51 2023 +0800

    [FLINK-30755][connector] Support getting attempt number from Sink context
---
 .../org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java     | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java
 
b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java
index 8dfa5f6..98f64ed 100644
--- 
a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java
+++ 
b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java
@@ -474,6 +474,11 @@ public class KafkaWriterITCase {
             return 1;
         }
 
+        @Override
+        public int getAttemptNumber() {
+            return 0;
+        }
+
         @Override
         public SinkWriterMetricGroup metricGroup() {
             return metricGroup;