All Versions
112
Latest Version
Avg Release Cycle
5 days
Latest Release
881 days ago

Changelog History
Page 10

  • v0.3.0 Changes

    • 👀 Switched from custom ParserError for each parser to general catching of Karafka::Errors::ParseError and its descendants
    • Gem bump
    • 🛠 Fixed #32 - now when using custom workers that does not inherit from Karafka::BaseWorker perform method is not required. Using custom workers means that the logic that would normally lie under #perform, needs to be executed directly from the worker.
    • 🛠 Fixed #31 - Technically didn't fix because this is how Sidekiq is meant to work, but provided possibility to assign custom interchangers that allow to bypass JSON encoding issues by converting data that goes to Redis to a required format (and parsing it back when it is fetched)
    • Added full parameters lazy load - content is no longer loaded during #perform_async if params are not used in before_enqueue
    • 0️⃣ No more namespaces for Redis by default (use separate DBs)

  • v0.1.21 Changes

    • Sidekiq 4.0.1 bump
    • Gem bump
    • ➕ Added direct celluloid requirement to Karafka (removed from Sidekiq)

  • v0.1.19 Changes

    • ⏱ Internal call - schedule naming change
    • Enqueue to perform_async naming in controller to follow Sidekiqs naming convention
    • Gem bump

  • v0.1.18 Changes

    • 🔄 Changed Redis configuration options into a single hash that is directly passed to Redis setup for Sidekiq
    • ➕ Added config.ru to provide a Sidekiq web UI (see README for more details)

  • v0.1.17 Changes

    • 🔄 Changed Karafka::Connection::Cluster tp Karafka::Connection::ActorCluster to distinguish between a single thread actor cluster for multiple topic connection and a future feature that will allow process clusterization.
    • ➕ Add an ability to use user-defined parsers for a messages
    • Lazy load params for before callbacks
    • 👷 Automatic loading/initializing all workers classes during startup (so Sidekiq won't fail with unknown workers exception)
    • Params are now private to controller
    • ➕ Added bootstrap method to app.rb

  • v0.1.16 Changes

    • Cluster level error catching for all exceptions so actor is not killer
    • 🌲 Cluster level error logging
    • 🔨 Listener refactoring (QueueConsumer extracted)
    • Karafka::Connection::QueueConsumer to wrap around fetching logic - technically we could replace Kafka with any other messaging engine as long as we preserve the same API
    • ➕ Added debug env for debugging purpose in applications

  • v0.1.15 Changes

    • Fixed max_wait_ms vs socket_timeout_ms issue
    • 🛠 Fixed closing queue connection after Poseidon::Errors::ProtocolError failure
    • 🛠 Fixed wrong logging file selection based on env
    • Extracted Karafka::Connection::QueueConsumer object to wrap around queue connection

  • v0.1.14 Changes

    • Rake tasks for listing all the topics on Kafka server (rake kafka:topics)

  • v0.1.13 Changes

    • 👷 Ability to assign custom workers and use them bypassing Karafka::BaseWorker (or its descendants)
    • Gem bump

  • v0.1.12 Changes

    • All internal errors went to Karafka::Errors namespace