@SuppressWarnings("varargs")
    @SafeVarargs
    private final int produceDataToTopic(final String topic,
                                         final DataTracker dataTracker,
                                         final long timestamp,
                                         final KeyValue<Integer, String>... keyValues) {
        produceDataToTopic(topic, timestamp, keyValues);

        for (final KeyValue<Integer, String> keyValue : keyValues) {
            dataTracker.add(keyValue.key, timestamp, keyValue.value);
        }

        return keyValues.length;
    }
@param topic       topic to produce to
@param dataTracker map of key -> timestamp -> value for tracking data which is produced to
                   the topic. This method will add the produced data into this in-memory
                   tracker in addition to producing to the topic, in order to keep the two
                   in sync.
@param timestamp   timestamp to produce with
@param keyValues   key-value pairs to produce

@return number of records produced
streams/src/test/java/org/apache/kafka/streams/integration/VersionedKeyValueStoreIntegrationTest.java