in src/main/java/org/apache/geode/kafka/sink/GeodeKafkaSinkTask.java [95:98]
public void put(Collection<SinkRecord> records) { logger.debug("Received " + records.size() + " records."); put(records, new HashMap<>()); }