Related to: https://issues.apache.org/jira/browse/FLINK-9402
A fix (Flink-9402) was introduced to force the configurations to have exactly one of "aws.region" or "aws.endpoint", but the underlying problem wasn't entirely fixed.
If "aws.endpoint" is set and "aws.region" is unset, a different exception is thrown, instead.
In KinesisConfigUtil.java, getValidatedProducerConfiguration() calls:
Where the original fix was introduced ("aws.region" XOR "aws.endpoint")
But a couple of lines later, getValidatedProducerConfiguration() then calls:
Which explicitly checks for the existence of "aws.region", and throws an exception if it is not set.
Thus, this class needs to be fixed such that "aws.region" is only required if "aws.endpoint" is unset, as the original ticket indicated.
Also, validateAwsConfiguration() has a minor bug where is labels the "aws.endpoint" incorrectly.
But should be: