All notable changes to this project will be documented in this file. This change log follows the conventions of keepachangelog.com.
ottla.core/ensure-subscriptionottla.core/add-subscription! for explicit subscription creationottla.core/remove-subscription! to delete a consumer group subscription(status consumer) now returns a map with :state, :topic, :group, :record-count, and :last-processed-atappend! and append-one! now return the largest eid insertedcommit-offset! and reset-consumer-offset! now return a boolean indicating whether the subscription was updatedreset-consumer-offset! now effectively nullifies updated_at for more consistent reporting:selections options instead of :topics for list-subscriptions and topic-subscriptionsottla.core/trim-topic! for log retention and cleanupottla.core/list-subscriptions:index-key? option for add-topic! and ensure-topic (with default false):max-records option to consumer to cap batch size (with default 100)ottla.core/topic-subscriptions to the public API:updated-at field in subscriptionsclojure.tools.logging instead of println for warnings and errorsottla.core/ensure-topic for idempotent topic creationtopic-subscriptions for getting summaries of subscriptions to
topics and their offsets.commit-offset! for manual commit modereset-consumer-offset! to do "rewind":val-type to :value-type in parameters for consistencyottla.core/append to ottla.core/append! to make naming convention.Initial public release
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 |