public String getBootstrapServers()

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

• 15 lines of code
• 4 McCabe index (conditional complexity)

	public String getBootstrapServers() {
		if (this.conf.get(KAFKA_BOOTSTRAP_SERVERS) != null) {
			KafkaConfigurationUtil.bootstraps = this.conf.get(KAFKA_BOOTSTRAP_SERVERS);
			return this.conf.get(KAFKA_BOOTSTRAP_SERVERS);
		} else 
		if (KafkaConfigurationUtil.bootstraps == null) {
			if ( this.getMskArn() != null ) {
				GetBootstrapBrokersRequest request = new GetBootstrapBrokersRequest().withClusterArn(this.getMskArn());
				AWSKafka mskClient =  AWSKafkaClient.builder().standard().build();
				GetBootstrapBrokersResult result = mskClient.getBootstrapBrokers(request);
				KafkaConfigurationUtil.bootstraps = result.getBootstrapBrokerString();
			}
		}
		return KafkaConfigurationUtil.bootstraps;
	}