jackdaw.test.transports.mock

mock-consumer

(mock-consumer driver topic-config deserializers)

mock-producer

(mock-producer driver topic-config serializers on-input)

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-output-record

(with-output-record topic-config)