(mock-consumer driver topic-config deserializers)Builds a test-machine consumer over TopologyTestDriver driver that polls
topic-config's output topics, deserializes each record with deserializers
and reverse-maps it to its logical topic. Returns the consumer with its
message stream and lifecycle atoms.
Builds a test-machine consumer over TopologyTestDriver `driver` that polls `topic-config`'s output topics, deserializes each record with `deserializers` and reverse-maps it to its logical topic. Returns the consumer with its message stream and lifecycle atoms.
(mock-producer driver topic-config serializers on-input)Builds a test-machine producer over TopologyTestDriver driver that
serializes input records with serializers and pipes them into the topology,
calling on-input for each fed record.
Builds a test-machine producer over TopologyTestDriver `driver` that serializes input records with `serializers` and pipes them into the topology, calling `on-input` for each fed record.
(set-headers consumer-record headers)Adds each entry of the headers map onto consumer-record's Kafka record
headers, returning the record.
Adds each entry of the `headers` map onto `consumer-record`'s Kafka record headers, returning the record.
(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)Returns a fn that converts a Kafka output record read from the test driver
into a {:topic :key :value ...} map.
Returns a fn that converts a Kafka output record read from the test driver
into a `{:topic :key :value ...}` map.cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |