All notable changes to Gregor will be documented in this file.
KafkaConsumer2.0.00.11.0.00.11.0.0topics which lists existing Kafka topics.0.10.0.1kafka.admin.AdminUtils/createTopic acquired another argument in 0.10. It's an
additional optional argument for create-topic.Topic management via Pull Request #5:
create-topic: Create a new topic.topic-exists?: Check if a topic exists.delete-topic: Delete an existing topic.NullPointerException in the rebalance listener.clojure.core/flush and clojure.core/send.Apologies for the several (pretty minor) breaking changes.
resume and pause now aligns with the rest of the API (assoc-like
optional arg pairs)commit-offsets-async! and commit-offsets! optional arg offsets is now a seq of
maps with :topic, :partition, :offset and optional :metadata keys.commited now returns nil or a map with :offset and :metadata keys.send no longer supports a callback, use send-then instead.seek-to! arg is now named offset.send has new arities that correspond to those of the ProducerRecord constructor.resume and pause no longer have the same implementation.lambdahands which fixes issue w/ overwritten custom
(de)serializers in producer and consumer configs.send-then function which provides send a callback. This callback expects a map of
metadata and an exception as its args.->producer-record function.Can you improve this documentation?Edit on GitHub
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 |