Skip to content

Latest commit

 

History

History
25 lines (16 loc) · 472 Bytes

kafka-streams-TopologyTestDriver.adoc

File metadata and controls

25 lines (16 loc) · 472 Bytes

TopologyTestDriver

TopologyTestDriver is…​FIXME

getAllStateStores Method

Map<String, StateStore> getAllStateStores()

getAllStateStores…​FIXME

Note
 getAllStateStores is used when…​FIXME

pipeInput Method

void pipeInput(final ConsumerRecord<byte[], byte[]> consumerRecord)

pipeInput…​FIXME

Note
 pipeInput is used when…​FIXME