Skip to content

Commit 54eea36

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

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
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

0 commit comments

Comments
 (0)