jackdaw.test.transports.mock — fundingcircle/jackdaw 0.6.6

mock-consumer clj

(mock-consumer driver topic-config deserializers)

mock-producer clj

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

with-input-record clj

(with-input-record topic-config)

Creates a kafka ConsumerRecord to be fed directly into a topology source node by the TopologyTestDriver

with-output-record clj

(with-output-record topic-config)