All notable changes to Gregor will be documented in this file.
- upgrade to Kafka
0.11.0.0
- Fix rack-aware-mode-constant by replacing class with object instance.
- new function
topicswhich lists existing Kafka topics.
- upgrade to Kafka
0.10.0.1 kafka.admin.AdminUtils/createTopicacquired another argument in0.10. It's an additional optional argument forcreate-topic.
- fix producer doc link
- remove unused Java class import
- Closeable protocol for consumers and producers via Pull Request #9 which includes closing a producer with a timeout in seconds.
- Use Kafka 0.9 compiled with Scala 2.11 instead of 2.10 because the Kafka maintainers recommend to do so.
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.
- Pull Request #7: Avoid a
NullPointerExceptionin the rebalance listener. - Pull Request #4: Exclude
clojure.core/flushandclojure.core/send.
- vars for byte-array (de)serializers
Apologies for the several (pretty minor) breaking changes.
- Arity of
resumeandpausenow aligns with the rest of the API (assoc-like optional arg pairs) commit-offsets-async!andcommit-offsets!optional argoffsetsis now a seq of maps with:topic,:partition,:offsetand optional:metadatakeys.commitednow returnsnilor a map with:offsetand:metadatakeys.sendno longer supports a callback, usesend-theninstead.
- Second
seek-to!arg is now namedoffset. sendhas new arities that correspond to those of theProducerRecordconstructor.
resumeandpauseno longer have the same implementation.- Merge pull request from
lambdahandswhich fixes issue w/ overwritten custom (de)serializers in producer and consumer configs.
send-thenfunction which providessenda callback. This callback expects a map of metadata and an exception as its args.->producer-recordfunction.
- First public release: added most of API