public void open()

in src/main/java/com/amazon/kinesis/kafka/AmazonKinesisSinkTask.java [312:318]

• 7 lines of code
• 3 McCabe index (conditional complexity)

	public void open(Collection<TopicPartition> partitions) {
		if (singleKinesisProducerPerPartition) {
			for (TopicPartition topicPartition : partitions) {
				producerMap.put(topicPartition.partition() + "@" + topicPartition.topic(), getKinesisProducer());
			}
		}
	}