package org.apache.kafka.clientsstreams;

//Newpublic Interfaceclass toTopologyTestDriver make{
 possible to use ProducereRecord inpublic TopologyTestDriver
//ConsumerRecord not modified to implement this because timestamp() return long, not Long
public interface ClientRecord<K, V> {
    String topic((Topology topology, Properties config); // existing constructor
    @Deprecate public TopologyTestDriver(Topology topology, Properties config, long initialWallClockTimeMs);
    Headerspublic headersTopologyTestDriver();
Topology topology, Properties config, KInstant key(initialWallClockTime);

    V value(@Deprecate public void advanceWallClockTime(long advanceMs);
 // can  Long timestamp();
}

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 configureTimingparameters:
    //startTimestampMsstartTimestamp the initial timestamp for generated records, if not provided uses current system time as start timestamp.
    //autoAdvanceMsautoAdvance 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 advanceTimeMsadvanceTime(final longDuration advanceMsadvance);

	//Methods to pipe single record
    void pipeInput(final V value);
    void pipeInput(final K key, final V value);

    // Use provided timestamp, does not auto advance internally tracked time.
    void pipeInput(final V value, final longInstant timestampMstimestamp);

    void pipeInput(final K key, final V value, final Instant timestamp);

    // Method with long provided to support easier migration of old tests
   void pipeInput(final K key, final V value, final long timestampMs);

    void pipeInput(final ClientRecord<K, V> record);// If record timestamp set, does not auto advance internally tracked time.
    void pipeInput(final ClientRecord<KTestRecord<K, V> record, final long timestampMs);

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

 List<KeyValue<K, V>> keyValues);

    // Use provided timestamp, does not auto advance internally tracked time.
    void pipeKeyValueListpipeValueList(final List<KeyValue<K, V>> keyValuesList<V> values, final Instant startTimestamp, final Duration advanceMs);
    void pipeKeyValueList(final List<KeyValue<K, V>> keyValues, final longInstant startTimestamp, final longDuration advanceMs);

    // If voidrecord pipeRecordList(finaltimestamp List<ClientRecord<Kset, V>> records); does not auto advance internally tracked time.
    void pipeRecordList(final List<ClientRecord<KList<? extends TestRecord<K, V>> records, final long startTimestamp, final long advanceMs);
}

package org.apache.kafka.streams.test;

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

	//Method to check queue size
    final long getQueueSize();
    final boolean isEmpty();

	//Methods to readOutput, throw NoSuchElement if no record in queue
    V readValue();
    KeyValue<K, V> readKeyValue();
    ClientRecord<KTestRecord<K, V> readRecord();

    //Output as collection
    List<V> readValuesToList();
    Map<KList<KeyValue<K, V>V>> readKeyValuesToMapreadKeyValuesToList();
    List<KeyValue<KMap<K, V>>V> readKeyValuesToListreadKeyValuesToMap();
    List<ClientRecord<KList<TestRecord<K, V>> readRecordToListreadRecordsToList();
}

package org.apache.kafka.streams.test;
public class TestRecord<K, V> {
	//OutputVerifierConstructors
 modified to accept ClientRecordpublic insteadTestRecord(final ofV ProducerRecord
public class OutputVerifier {
 value);
    public TestRecord(final K key, final V value);
    public TestRecord(final staticK <Kkey,V> final voidV compareValue(ClientRecord<Kvalue, V>final record, V expectedValue) throws AssertionErrorHeaders headers);
    public TestRecord(final staticK <Kkey,V> void compareValue(ClientRecord<K, V> record, ClientRecord<K, V> expectedRecord) throws AssertionErrorfinal V value, final Instant recordTime);
 
   public publicTestRecord(final staticK <Kkey,V> final voidV compareKeyValue(ClientRecord<Kvalue, final V>Headers recordheaders, Kfinal expectedKey, V expectedValue) throws AssertionErrorInstant recordTime);
    public TestRecord(final staticK <Kkey,V> final voidV compareKeyValue(ClientRecord<Kvalue, final V>Headers recordheaders, ClientRecord<K,final V>Long expectedRecord) throws AssertionError;
 timestamp);
	
	//Constructor based on existing record
    public staticTestRecord(final <KConsumerRecord<K, V> void compareValueTimestamp(ClientRecord<K record);
    public TestRecord(final ProducerRecord<K, V> record, V expectedValue, long expectedTimestamp) throws AssertionError;);
	
	// Methods like in ProducerRecord / ConsumerRecord
    public static <K,V> void compareValueTimestamp(ClientRecord<K, V> record, ClientRecord<K, V> expectedRecord) throws AssertionError;
  Headers headers();
    public K key();
    public V value();
    public Long timestamp();

	// Getters
    public static <K,V> void compareKeyValueTimestamp(ClientRecord<K, V> record, K expectedKey, V expectedValue, long expectedTimestamp) throws AssertionError Headers getHeaders();
    public K getKey();
    public V getValue();
    public Instant getRecordTime();
	
	//Overrides
    public String toString();
    public static <K,V> void compareKeyValueTimestamp(ClientRecord<K, V> record, ClientRecord<K, V> expectedRecord) throws AssertionError;
 
}boolean equals(Object o);
    public int hashCode();
}

package org.apache.kafka.streams.test;

//Similar functionality now in TestInputTopic
@Deprecated
public class ConsumerRecordFactory<K, V> {
...