public void close()

in src/main/java/com/amazon/kinesis/kafka/AmazonKinesisSinkTask.java [320:327]

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

	public void close(Collection<TopicPartition> partitions) {
		if (singleKinesisProducerPerPartition) {
			for (TopicPartition topicPartition : partitions) {
				producerMap.get(topicPartition.partition() + "@" + topicPartition.topic()).destroy();
				producerMap.remove(topicPartition.partition() + "@" + topicPartition.topic());
			}
		}
	}