xiaolong-sn commented on a change in pull request #12920:
URL: https://github.com/apache/flink/pull/12920#discussion_r457109772
##########
File path:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java
##########
@@ -159,6 +174,54 @@ public static void
validateConsumerConfiguration(Properties config) {
validateOptionalPositiveDoubleProperty(config,
ConsumerConfigConstants.LIST_SHARDS_BACKOFF_EXPONENTIAL_CONSTANT,
"Invalid value given for list shards operation backoff
exponential constant. Must be a valid non-negative double value.");
+ validateOptionalPositiveIntProperty(config,
ConsumerConfigConstants.REGISTER_STREAM_RETRIES,
+ "Invalid value given for maximum retry attempts for
register stream operation. Must be a valid non-negative integer value.");
+
+ validateOptionalPositiveLongProperty(config,
ConsumerConfigConstants.REGISTER_STREAM_BACKOFF_BASE,
+ "Invalid value given for register stream operation base
backoff milliseconds. Must be a valid non-negative long value.");
+
+ validateOptionalPositiveLongProperty(config,
ConsumerConfigConstants.REGISTER_STREAM_BACKOFF_MAX,
+ "Invalid value given for register stream operation max
backoff milliseconds. Must be a valid non-negative long value.");
+
+ validateOptionalPositiveDoubleProperty(config,
ConsumerConfigConstants.REGISTER_STREAM_BACKOFF_EXPONENTIAL_CONSTANT,
+ "Invalid value given for register stream operation
backoff exponential constant. Must be a valid non-negative double value.");
+
+ validateOptionalPositiveIntProperty(config,
ConsumerConfigConstants.DEREGISTER_STREAM_RETRIES,
+ "Invalid value given for maximum retry attempts for
deregister stream operation. Must be a valid non-negative integer value.");
+
+ validateOptionalPositiveLongProperty(config,
ConsumerConfigConstants.DEREGISTER_STREAM_BACKOFF_BASE,
+ "Invalid value given for deregister stream operation
base backoff milliseconds. Must be a valid non-negative long value.");
+
+ validateOptionalPositiveLongProperty(config,
ConsumerConfigConstants.DEREGISTER_STREAM_BACKOFF_MAX,
+ "Invalid value given for deregister stream operation
max backoff milliseconds. Must be a valid non-negative long value.");
+
+ validateOptionalPositiveDoubleProperty(config,
ConsumerConfigConstants.DEREGISTER_STREAM_BACKOFF_EXPONENTIAL_CONSTANT,
+ "Invalid value given for deregister stream operation
backoff exponential constant. Must be a valid non-negative double value.");
+
+ validateOptionalPositiveIntProperty(config,
ConsumerConfigConstants.LIST_STREAM_RETRIES,
Review comment:
All is renamed.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
