protected KinesisProducerConfiguration getKPLConfiguration()

in kinesis-sink/src/main/java/com/amazonaws/hbase/datasink/KinesisConfigurationUtil.java [96:113]

17 lines of code
1 McCabe index (conditional complexity)


	protected KinesisProducerConfiguration getKPLConfiguration() {
		this.kplConfig = new KinesisProducerConfiguration()
				.setMaxConnections(this.getStreamMaxConnection())
				.setRequestTimeout(this.getStreamRequestTimeout())
				.setAggregationEnabled(this.isKPLAggregationEnabled())
				.setRegion(this.getStreamRegion())
				.setKinesisEndpoint(this.getKinesisEndpoint())
				.setKinesisPort(this.getKinesisEndpointPort())
				.setLogLevel(this.getKplLogLevel())
				.setMetricsLevel(this.getKplMetricLevel())
				.setVerifyCertificate(this.getVerifySSLCert())
				.setCloudwatchEndpoint(this.getCloudWatchEndpoint())
				.setCloudwatchPort(this.getCloudWatchEndpointPort())
				.setRecordTtl(this.getRecordTTL())
				.setRecordMaxBufferedTime(this.getRecordMaxBufferedtime());
		
		return this.kplConfig;
	}