Skip to content

Commit 8ea4c54

Browse files
committed
Update delivery timeout config comments in tests
Signed-off-by: Thomas Cooper <[email protected]>
1 parent 8547d9a commit 8ea4c54

File tree

2 files changed

+28
-26
lines changed

2 files changed

+28
-26
lines changed

flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterFaultToleranceITCase.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,8 @@ public class KafkaWriterFaultToleranceITCase extends KafkaWriterTestBase {
4040
private static final String INIT_KAFKA_RETRIES = "0";
4141
private static final String INIT_KAFKA_REQUEST_TIMEOUT_MS = "1000";
4242
private static final String INIT_KAFKA_MAX_BLOCK_MS = "1000";
43+
/** The delivery timeout has to be greater than the request timeout as the
44+
* latter is part of the former and this is enforced by a compile time check. */
4345
private static final String INIT_KAFKA_DELIVERY_TIMEOUT_MS = "1500";
4446

4547
@RegisterExtension

pom.xml

Lines changed: 26 additions & 26 deletions
Original file line numberDiff line numberDiff line change
@@ -28,10 +28,10 @@ under the License.
2828
<modelVersion>4.0.0</modelVersion>
2929

3030
<artifactId>flink-connector-kafka-parent</artifactId>
31-
<version>4.0-SNAPSHOT</version>
32-
<name>Flink : Connectors : Kafka : Parent</name>
33-
<packaging>pom</packaging>
34-
<inceptionYear>2022</inceptionYear>
31+
<version>4.0-SNAPSHOT</version>
32+
<name>Flink : Connectors : Kafka : Parent</name>
33+
<packaging>pom</packaging>
34+
<inceptionYear>2022</inceptionYear>
3535

3636
<scm>
3737
<url>https://github.com/apache/flink-connector-kafka</url>
@@ -48,34 +48,34 @@ under the License.
4848
<module>flink-python</module>
4949
</modules>
5050

51-
<properties>
52-
<flink.version>2.0.0</flink.version>
53-
<kafka.version>4.0.0</kafka.version>
54-
<confluent.version>7.9.2</confluent.version>
51+
<properties>
52+
<flink.version>2.0.0</flink.version>
53+
<kafka.version>4.0.0</kafka.version>
54+
<confluent.version>7.9.2</confluent.version>
5555

56-
<jackson-bom.version>2.16.2</jackson-bom.version>
57-
<junit4.version>4.13.2</junit4.version>
58-
<junit5.version>5.9.1</junit5.version>
59-
<assertj.version>3.23.1</assertj.version>
60-
<testcontainers.version>1.21.2</testcontainers.version>
56+
<jackson-bom.version>2.16.2</jackson-bom.version>
57+
<junit4.version>4.13.2</junit4.version>
58+
<junit5.version>5.9.1</junit5.version>
59+
<assertj.version>3.23.1</assertj.version>
60+
<testcontainers.version>1.21.2</testcontainers.version>
6161
<docker-java.version>3.5.1</docker-java.version>
62-
<mockito.version>3.4.6</mockito.version>
63-
<powermock.version>2.0.9</powermock.version>
64-
<hamcrest.version>1.3</hamcrest.version>
65-
<byte-buddy.version>1.12.10</byte-buddy.version>
66-
<commons-cli.version>1.5.0</commons-cli.version>
67-
<scala.binary.version>2.12</scala.binary.version>
68-
<scala-reflect.version>2.12.20</scala-reflect.version>
69-
<scala-library.version>2.12.20</scala-library.version>
70-
<snappy-java.version>1.1.10.5</snappy-java.version>
71-
<avro.version>1.11.4</avro.version>
72-
<guava.version>32.1.2-jre</guava.version>
62+
<mockito.version>3.4.6</mockito.version>
63+
<powermock.version>2.0.9</powermock.version>
64+
<hamcrest.version>1.3</hamcrest.version>
65+
<byte-buddy.version>1.12.10</byte-buddy.version>
66+
<commons-cli.version>1.5.0</commons-cli.version>
67+
<scala.binary.version>2.12</scala.binary.version>
68+
<scala-reflect.version>2.12.20</scala-reflect.version>
69+
<scala-library.version>2.12.20</scala-library.version>
70+
<snappy-java.version>1.1.10.5</snappy-java.version>
71+
<avro.version>1.11.4</avro.version>
72+
<guava.version>32.1.2-jre</guava.version>
7373

7474
<japicmp.skip>false</japicmp.skip>
7575
<japicmp.referenceVersion>1.17.0</japicmp.referenceVersion>
7676

77-
<slf4j.version>1.7.36</slf4j.version>
78-
<log4j.version>2.24.3</log4j.version>
77+
<slf4j.version>1.7.36</slf4j.version>
78+
<log4j.version>2.24.3</log4j.version>
7979

8080
<flink.parent.artifactId>flink-connector-kafka-parent</flink.parent.artifactId>
8181

0 commit comments

Comments
 (0)