private void flush()

in sample-kinesis-producer/src/main/java/com/optimize/downstream/samplekinesisproducer/IOTDeviceConsumerFromBlockingQueueToKinesisStreams.java [62:69]

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

    private void flush() {
        System.out.println("Sending a record to Kinesis Stream with " + entries.size() + " messages grouped together.");
        kinesis.putRecords(new PutRecordsRequest()
                .withStreamName(STREAM_NAME)
                .withRecords(entries));
        entries.clear();

    }