public Properties getConfigurationProperties()

in kafka-sink/src/main/java/com/amazonaws/hbase/datasink/KafkaConfigurationUtil.java [262:281]

18 lines of code
7 McCabe index (conditional complexity)


	public Properties getConfigurationProperties() {
		Properties props = new Properties();
        props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, this.getBootstrapServers());
        props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
        props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, ByteBufferSerializer.class.getName());
        props.put(ProducerConfig.BATCH_SIZE_CONFIG, this.getBatchSize());
        props.put(ProducerConfig.TRANSACTION_TIMEOUT_CONFIG, this.getTransactionTimeout());
        props.put(ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG,this.getRequestTimeout());
        props.put(ProducerConfig.RETRIES_CONFIG,this.getRetries());
        props.put(ProducerConfig.RETRY_BACKOFF_MS_CONFIG,this.getRetryBackoff());
        if ( this.getSecurityProtocol() != null ) props.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG,this.getSecurityProtocol());
        if ( this.getSecuritySSLKeyStoreLocation() != null ) props.put(SslConfigs.SSL_KEYSTORE_LOCATION_CONFIG, this.getSecuritySSLKeyStoreLocation());
        if ( this.getSecuritySSLTrustStoreLocation() != null ) props.put(SslConfigs.SSL_TRUSTSTORE_LOCATION_CONFIG, this.getSecuritySSLTrustStoreLocation());
        if ( this.getSecuritySSLKeyPassword() != null ) props.put(SslConfigs.SSL_KEY_PASSWORD_CONFIG, this.getSecuritySSLKeyPassword());
        if ( this.getSecuritySSLTrustStorePassword() != null ) props.put(SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG, this.getSecuritySSLTrustStorePassword());
        if ( this.getSecuritySSLKeyPassword() != null ) props.put(SslConfigs.SSL_KEY_PASSWORD_CONFIG, this.getSecuritySSLKeyPassword());
        
		return props;
		
	}