Karafka v1.3.0.rc1 Release Notes

Release Date: 2019-07-31 // over 4 years ago
    • ⬇️ Drop support for Kafka 0.10 in favor of native support for Kafka 0.11.
    • ⚡️ Update ruby-kafka to the 0.7 version
    • 👌 Support messages headers receiving
    • Message bus unification
    • 📇 Parser available in metadata
    • Cleanup towards moving to a non-global state app management
    • ⬇️ Drop Ruby 2.3 support
    • 👌 Support for Ruby 2.6.3
    • 🚚 Karafka::Loader has been removed in favor of Zeitwerk
    • Schemas are now contracts
    • 🚚 #393 - Reorganize responders - removed multiple_usage constrain
    • #388 - ssl_client_cert_chain sync
    • 🔀 #300 - Store value in a value key and replace its content with parsed version - without root merge
    • 🏗 #331 - Disallow building groups without topics
    • 👍 #340 - Instrumentation unification. Better and more consistent naming
    • #340 - Procline instrumentation for a nicer process name
    • #342 - Change default for fetcher_max_queue_size from 100 to 10 to lower max memory usage
    • #345 - Cleanup exceptions names
    • #341 - Split connection delegator into batch delegator and single_delegator
    • 📜 #351 - Rename #retrieve! to #parse! on params and #parsed to parse! on params batch.
    • 📜 #351 - Adds '#first' for params_batch that returns parsed first element from the params_batch object.
    • 📜 #360 - Single params consuming mode automatically parses data specs
    • #359 - Divide mark_as_consumed into mark_as_consumed and mark_as_consumed!
    • #356 - Provide a #values for params_batch to extract only values of objects from the params_batch
    • 🔒 #363 - Too shallow ruby-kafka version lock
    • #354 - Expose consumer heartbeat
    • 🚚 #377 - Remove the persistent setup in favor of persistence
    • 📜 #375 - Sidekiq Backend parser mismatch
    • 👍 #369 - Single consumer can support more than one topic
    • 👍 #288 - Drop dependency on activesupport gem
    • #371 - SASL over SSL
    • 📇 #392 - Move params redundant data to metadata
    • 📇 #335 - Metadata access from within the consumer
    • 🚑 #402 - Delayed reconnection upon critical failures
    • #405 - reconnect_timeout value is now being validated
    • 🚀 #437 - Specs ensuring that the #437 won't occur in the 1.3 release
    • #426 - ssl client cert key password
    • #444 - add certificate and private key validation
    • 📜 #460 - Decouple responder "parser" (generator?) from topic.parser (benissimo)
    • 📜 #463 - Split parsers into serializers / deserializers
    • 👍 #473 - Support SASL OAuthBearer Authentication
    • #475 - Disallow subscribing to the same topic with multiple consumers
    • #485 - Setting shutdown_timeout to nil kills the app without waiting for anything
    • #487 - Make listeners as instances
    • #29 - Consumer class names must have the word "Consumer" in it in order to work (Sidekiq backend)
    • #491 - irb is missing for console to work
    • #502 - Karafka process hangs when sending multiple sigkills
    • 👌 #506 - ssl_verify_hostname sync
    • ⬆️ #483 - Upgrade dry-validation before releasing 1.3
    • #492 - Use Zeitwerk for code reload in development
    • #508 - Reset the consumers instances upon reconnecting to a cluster
    • 💎 #530 - expose ruby and ruby-kafka version
    • 534 - Allow to use headers in the deserializer object
    • 👍 #319 - Support for exponential backoff in pause