THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
package org.apache.kafka.streams.test;
public class TopologyTestDriver {
public TopologyTestDriver(Topology topology, Properties config); // initialized WallClockMockTimeMs with System.currentTimeMillis()
public TopologyTestDriver(Topology topology, Properties config, long initialWallClockTimeMs);
// event-time is automatically advanced based on the provided input records, and thus event-time punctuation are triggered automatically
// wall-clock time is mocked and not advanced automatically; user can advance wall-clock time manually, and thus, trigger wall-clock time punctuations manually
public void pipeInput(ConsumerRecord<byte[], byte[]> record); // can trigger event-time punctuation
public void pipeInput(List<ConsumerRecord<byte[], byte[]>> records); // can trigger event-time punctuation
public void advanceWallClockTime(long advanceMs); // can trigger wall-clock-time punctuation
// methods for result verification
public ProducerRecord<byte[], byte[]> readOutput(String topic);
public <K, V> ProducerRecord<K, V> readOutput(String topic, Deserializer<K> keyDeserializer, Deserializer<V> valueDeserializer);
public Map<String, StateStore> getAllStateStores()
public StateStore getStateStore(String name);
public <K, V> KeyValueStore<K, V> getKeyValueStore(String name);
public <K, V> WindowStore<K, V> getWindowStore(String name);
public <K, V> SessionStore<K, V> getSessionStore(String name);
public void close();
} |
...