(mock-consumer driver topic-config deserializers)
(mock-producer driver topic-config serializers on-input)
(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
(with-output-record _topic-config)
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close