tomncooper commented on code in PR #161:
URL:
https://github.com/apache/flink-connector-kafka/pull/161#discussion_r2030882248
##########
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterFaultToleranceITCase.java:
##########
@@ -40,7 +40,7 @@ public class KafkaWriterFaultToleranceITCase extends
KafkaWriterTestBase {
private static final String INIT_KAFKA_RETRIES = "0";
private static final String INIT_KAFKA_REQUEST_TIMEOUT_MS = "1000";
private static final String INIT_KAFKA_MAX_BLOCK_MS = "1000";
- private static final String INIT_KAFKA_DELIVERY_TIMEOUT_MS = "1000";
+ private static final String INIT_KAFKA_DELIVERY_TIMEOUT_MS = "1500";
Review Comment:
Sorry, I should have put a comment in the PR description about this. The new
kafka client now enforces the requirement for the delivery timeout to be longer
than the request timeout (which is part of the overall delivery timeout) at
compile time.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
