jackdaw.test.transports.mock
with-input-record
(with-input-record topic-config)
Creates a kafka ConsumerRecord to be fed directly into a topology source node by the TopologyTestDriver
(with-input-record topic-config)
Creates a kafka ConsumerRecord to be fed directly into a topology source node by the TopologyTestDriver