skidder opened a new pull request #8444: [FLINK-10190] [Kinesis Connector] Allow AWS_REGION to be supplied along with custom Kinesis endpoint URL: https://github.com/apache/flink/pull/8444 ## What is the purpose of the change Allow an AWS region (e.g. `us-east-1`) to be supplied along with a custom Kinesis endpoint in the Kinesis configuration. Using a [Kinesis VPC endpoint](https://aws.amazon.com/blogs/aws/new-aws-privatelink-endpoints-kinesis-ec2-systems-manager-and-elb-apis-in-your-vpc/) can prevent traffic leaving the AWS network. This greatly reduces costs by eliminating NAT traversal and cross-AZ transfers. However, this requires that the Kinesis endpoint URL be signed for a specific region. This is accomplished by including the region name along with the endpoint URL when constructing the Kinesis client. ## Brief change log - Permit both region and endpoint to be set - Set the region on the endpoint configuration when both region and endpoint are set ## Verifying this change This change added tests and can be verified by running connector unit tests. ## Does this pull request potentially affect one of the following parts: No ## Documentation Documentation for the Kinesis connector has been updated.
---------------------------------------------------------------- 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: us...@infra.apache.org With regards, Apache Git Services
