public static <K, V> void produceKeyValuesSynchronouslyWithTimestamp(final String topic,
                                                                         final Collection<KeyValue<K, V>> records,
                                                                         final Properties producerConfig,
                                                                         final Long timestamp) {
        produceKeyValuesSynchronouslyWithTimestamp(topic, records, producerConfig, timestamp, false);
    }
@param topic               Kafka topic to write the data records to
@param records             Data records to write to Kafka
@param producerConfig      Kafka producer configuration
@param timestamp           Timestamp of the record
@param <K>                 Key type of the data records
@param <V>                 Value type of the data records
streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java