Liking cljdoc? Tell your friends :D

jackdaw.test.transports.mock


identity-serializerclj

source

mock-consumerclj

(mock-consumer driver topic-config deserializers)
source

mock-producerclj

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

set-headersclj

(set-headers consumer-record headers)
source

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
sourceraw docstring

with-output-recordclj

(with-output-record _topic-config)
source

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

× close