@ Override protected AmazonKinesis createKinesisClient ( Properties configProps ) { ClientConfiguration awsClientConfig = new ClientConfigurationFactory ( ) . getConfig ( ) ; setAwsClientConfigProperties ( awsClientConfig , configProps ) ; AWSCredentialsProvider credentials = getCredentialsProvider ( configProps ) ; awsClientConfig . setUserAgentPrefix ( String . format ( USER_AGENT_FORMAT , EnvironmentInformation . getVersion ( ) , EnvironmentInformation . getRevisionInformation ( ) . commitId ) ) ; AmazonDynamoDBStreamsAdapterClient adapterClient = new AmazonDynamoDBStreamsAdapterClient ( credentials , awsClientConfig ) ; if ( configProps . containsKey ( AWS_ENDPOINT ) ) { adapterClient . setEndpoint ( configProps . getProperty ( AWS_ENDPOINT ) ) ; } else { adapterClient . setRegion ( Region . getRegion ( Regions . fromName ( configProps . getProperty ( AWS_REGION ) ) ) ) ; } return adapterClient ; }
Creates an AmazonDynamoDBStreamsAdapterClient . Uses it as the internal client interacting with the DynamoDB streams .