Liking cljdoc? Tell your friends :D

cddr.kafka.test.transports.mock


mock-consumerclj

(mock-consumer driver topic-config deserializers)

mock-producerclj

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

set-headersclj

(set-headers consumer-record headers)

with-input-recordclj

(with-input-record _topic-config)

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

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

with-output-recordclj

(with-output-record _topic-config)

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close