« Changelog History


Karafka v1.1.0 Release Notes

    • Gem bump
    • Switch from Celluloid to native Thread management
    • 👌 Improved shutdown process
    • 🚚 Introduced optional fetch callbacks and moved current the after_received there as well
    • 🚩 Karafka will raise Errors::InvalidPauseTimeout exception when trying to pause but timeout set to 0
    • 👍 Allow float for timeouts and other time based second settings
    • 📇 Renamed MessagesProcessor to Processor and MessagesConsumer to Consumer - we don't process and don't consumer anything else so it was pointless to keep this "namespace"
    • 🚚 #232 - Remove unused ActiveSupport require
    • #214 - Expose consumer on a controller layer
    • #193 - Process shutdown callbacks
    • 🛠 Fixed accessibility of #params_batch from the outside of the controller
    • connection_pool config options are no longer required
    • celluloid config options are no longer required
    • 🗄 #perform is now renamed to #consume with warning level on using the old one (deprecated)
    • #235 - Rename perform to consume
    • ⬆️ Upgrade to ruby-kafka 0.5
    • Due to redesign of Waterdrop concurrency setting is no longer needed
    • #236 - Manual offset management
    • 👍 WaterDrop 1.0.0 support with async
    • Renamed batch_consuming option to batch_fetching as it is not a consumption (with processing) but a process of fetching messages from Kafka. The messages is considered consumed, when it is processed.
    • 🖨 Renamed batch_processing to batch_consuming to resemble Kafka concept of consuming messages.
    • Renamed after_received to after_fetched to normalize the naming conventions.
    • 👍 Responders support the per topic async option.