package org.apache.kafka.streams;
 
@Deprecated
public class TopologyTestDriver {
	...
 
    @Deprecate public void pipeInput(ConsumerRecord<byte[], byte[]> record); // can trigger event-time punctuation
    @Deprecate public void pipeInput(List<ConsumerRecord<byte[], byte[]>> records); // can trigger event-time punctuation
 
    // methods for result verification
  
    @Deprecate public ProducerRecord<byte[], byte[]> readOutput(String topic);
    @Deprecate public <K, V> ProducerRecord<K, V> readOutput(String topic, Deserializer<K> keyDeserializer, Deserializer<V> valueDeserializer);
 
    ...
}

package org.apache.kafka.streams.test;

public class TestInputTopic<K, V> {
    //Create by TopologyTestDriver, Constructors are package private

    //Timestamp handling 
    //Record timestamp can be provided when piping input or use internally tracked time initialized configured with configureTiming:
    //startTimestampMs the initial timestamp for generated records, if not provided uses current system time as start timestamp.
    //autoAdvanceMs the time increment per generated record, if not provided auto-advance is disabled.

    void configureTiming(final long startTimestampMs, final long autoAdvanceMs);
    //Advances the internally tracked time.
    void advanceTimeMs(final long advanceMs);

	//Methods to pipe single record
    void pipeInput(final V value);
    void pipeInput(final KV keyvalue, final Vlong valuetimestampMs);

    void pipeInput(final VK valuekey, final longV timestampMsvalue);
    void pipeInput(final K key, final V value, final long timestampMs);

    void pipeInput(final K keyClientRecord<K, final V value, final Headers headersV> record);
    void pipeInput(final K keyClientRecord<K, finalV> V valuerecord, final Headers headers, final long timestampMs);

	//Methods to pipe list of records
    void pipeKeyValueListpipeValueList(final List<KeyValue<K, V>> keyValuesList<V> values);
    void pipeValueList(final List<V> values, final long startTimestamp, final long advanceMs);

    void pipeKeyValueList(final List<KeyValue<K, V>> keyValues);
    void pipeKeyValueList(final List<KeyValue<K, V>> keyValues, final long startTimestamp, final long advanceMs);

    void pipeRecordList(final List<ClientRecord<K, V>> records);
    void pipeValueListpipeRecordList(final List<ClientRecord<K, List<V>V>> valuesrecords, final long startTimestamp, final long advanceMs);
}