We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4856934 commit 0b1949cCopy full SHA for 0b1949c
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkTest.java
@@ -16,10 +16,11 @@
16
import org.apache.flink.streaming.api.lineage.LineageVertex;
17
18
import org.apache.kafka.clients.producer.ProducerRecord;
19
-import org.jetbrains.annotations.Nullable;
20
import org.junit.jupiter.api.BeforeEach;
21
import org.junit.jupiter.api.Test;
22
+import javax.annotation.Nullable;
23
+
24
import java.util.Collections;
25
import java.util.Optional;
26
import java.util.Properties;
0 commit comments