docs: @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;
  	}