package org.apache.kafka.streams.test;

public class ConsumerRecordFactory<K, V> {

    // default 
    public void process(byte[] key, byte[] value, long timestamp);
    public void process(byte[] key, byte[] value);ConsumerRecordFactory(String defaultTopicName, Serializer<K> keySerializer, Serializer<V> valueSerializer); // initialized startTimestampMs with System.currentTimeMillis() and autoAdvanceMs with zero
    public <K, V> void process(K key, V value, ConsumerRecordFactory(String defaultTopicName, Serializer<K> keySerializer, Serializer<V> valueSerializer, long timestampstartTimestampMs);
    public <KConsumerRecordFactory(String defaultTopicName, V> void process(K keySerializer<K> keySerializer, VSerializer<V> valuevalueSerializer, Serializer<K>long keySerializerstartTimestampMs, Serializer<V>long valueSerializerautoAdvanceMs);

    public// void process(byte[] value, long timestamp);
    public void process(byte[] value);no default topic name; requires to specify topic name in #create(...)
    public <V> void process(V valueConsumerRecordFactory(Serializer<K> keySerializer, Serializer<V> valueSerializer, long timestamp);
    public <V> void process(V valueConsumerRecordFactory(Serializer<K> keySerializer, Serializer<V> valueSerializer)

,    // see below; cf. TestRecrodFactorylong startTimestampMs);
    public void processConsumerRecordFactory(TestRecord record);
    public void process(List<TestRecord> recordsSerializer<K> keySerializer, Serializer<V> valueSerializer, long startTimestampMs, long autoAdvanceMs);

    public void punctuateWallClockTimeadvanceTimeMs();
    public void punctuateStreamTime(long advanceMs);


    // methods for result verification
 create single records with default topic name
    public ProducerRecord<byteConsumerRecord<byte[], byte[]> readOutputcreate(String topic);
    public <KK key, V>V ProducerRecord<Kvalue, V> readOutput(String topic, Deserializer<K> keyDeserializer, Deserializer<V> valueDeserializerlong timestampMs);

    public StateStore getStateStore(String name);
    public <K, V> KeyValueStore<K, V> getKeyValueStore(String nameConsumerRecord<byte[], byte[]> create(K key, V value);
    public <KConsumerRecord<byte[], V> KeyValueStore<Kbyte[]> create(V value, V> getWindowStore(String namelong timestampMs);
    public <KConsumerRecord<byte[], V> KeyValueStore<K, V> getSessionStore(String name);
}

package org.apache.kafka.streams.test;

public class TestRecord<K, V> {

    public TestRecord(String topicName, K key, V value, long timestamp, Serializer<K> keySerializer, Serializer<V> valueSerializerbyte[]> create(V value);


    // create list of records with default topic name
    public List<ConsumerRecord<byte[], byte[]>> create(List<KeyValue<K, V>> keyValues);
    public TestRecord(String topicNameList<ConsumerRecord<byte[], byte[]>> keycreate(List<KeyValue<K, byte[]V>> valuekeyValues, long timestamp);

    public String topicName(startTimestamp, long advanceMs);
    public byteList<ConsumerRecord<byte[] key();
    public, byte[]>> value();
    public long timestamp();
}

package org.apache.kafka.streams.test;

public class TestRecordFactory<K, V> {create(List<KeyValue<K, V>> keyValues, long startTimestamp);


    // createoverwrite recordsdefault fortopic aname
 single input topic
 public ConsumerRecord<byte[],  public TestRecordFactorybyte[]> create(String topicName, Serializer<K> keySerializer, Serializer<V> valueSerializer, Time time);


    public TestRecord<K, V> create(K key, V value, long timestamptimestampMs);
    public TestRecord<KConsumerRecord<byte[], V>byte[]> create(String topicName, K key, V value);
    // null-key
    public TestRecord<KConsumerRecord<byte[], V>byte[]> create(V value, long timestamp);
    public TestRecord<K, V> create(V value);
    public TestRecord<K, V> create(KeyValue<K, V> keyValue, long timestamp)String topicName, V value, long timestampMs);
    public TestRecord<KConsumerRecord<byte[], V>byte[]> create(KeyValue<KString topicName, V>V keyValuevalue);


    // those methods createallow listto ofaccess recordsregular baseas onwell listas of k-v-pairsglobal stores
    public List<TestRecord<KList<ConsumerRecord<byte[], V>>byte[]>> create(String topicName, List<KeyValue<K, V>> keyValues); // start timestamp from constructor Time object; timestamp auto increment by 1
    public List<TestRecord<KList<ConsumerRecord<byte[], V>>byte[]>> create(String topicName, List<KeyValue<K, V>> keyValues, long startTimestamp, long advanceMs); // timestamp auto increment by 1
    public List<TestRecord<KList<ConsumerRecord<byte[], V>>byte[]>> create(String topicName, List<KeyValue<K, V>> keyValues, long startTimestamp, long advanceMs);

}