public void flush()

in src/main/java/com/amazon/kinesis/kafka/AmazonKinesisSinkTask.java [110:126]

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

	public void flush(Map<TopicPartition, OffsetAndMetadata> arg0) {
		checkForEarlierPutException();

		if (singleKinesisProducerPerPartition) {
			producerMap.values().forEach(producer -> {
				if (flushSync)
					producer.flushSync();
				else
					producer.flush();
			});
		} else {
			if (flushSync)
				kinesisProducer.flushSync();
			else
				kinesisProducer.flush();
		}
	}