public void stop()

in src/main/java/com/amazon/kinesis/kafka/AmazonKinesisSinkTask.java [330:341]

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

	public void stop() {
		// destroying kinesis producers which were not closed as part of close
		if (singleKinesisProducerPerPartition) {
			for (KinesisProducer kp : producerMap.values()) {
				kp.flushSync();
				kp.destroy();
			}
		} else {
			kinesisProducer.destroy();
		}

	}