cddr.kafka.test.transports.mock — cddr/test-machine 1.0.1-1-gcbb4695

mock-consumer clj

(mock-consumer driver topic-config deserializers)

mock-producer clj

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

set-headers clj

(set-headers consumer-record headers)

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)