Karafka v1.2.0 Release Notes
-
- Spec improvements
- #260 - Specs missing randomization
- #251 - Shutdown upon non responding (unreachable) cluster is not possible
- ๐ #258 - Investigate lowering requirements on activesupport
- #246 - Alias consumer#mark_as_consumed on controller
- #259 - Allow forcing key/partition key on responders
- #267 - Styling inconsistency
- ๐ #242 - Support setting the max bytes to fetch per request
- ๐ #247 - Support SCRAM once released
- ๐ง #271 - Provide an after_init option to pass a configuration block
- #262 - Error in the monitor code for NewRelic
- ๐ #241 - Performance metrics
- #274 - Rename controllers to consumers
- ๐ #184 - Seek to
- #284 - Dynamic Params parent class
- #275 - ssl_ca_certs_from_system
- #296 - Instrument forceful exit with an error
- ๐ Replaced some of the activesupport parts with dry-inflector
- ๐ Lower ActiveSupport dependency
- โ Remove configurators in favor of the after_init block configurator
- ๐ Ruby 2.5.0 support
- ๐ Renamed Karafka::Connection::Processor to Karafka::Connection::Delegator to match incoming naming conventions
- ๐ Renamed Karafka::Connection::Consumer to Karafka::Connection::Client due to #274
- โ Removed HashWithIndifferentAccess in favor of a regular hash
- 0๏ธโฃ JSON parsing defaults now to string keys
- Lower memory usage due to less params data internal details
- ๐ Support multiple
after_init
blocks in favor of a single one - Renamed
received_at
toreceive_time
to follow ruby-kafka and WaterDrop conventions - ๐ Adjust internal setup to easier map Ruby-Kafka config changes
- System callbacks reorganization
- Added
before_fetch_loop
configuration block for early client usage (#seek
, etc) - Renamed
after_fetched
toafter_fetch
to normalize the naming convention - Instrumentation on a connection delegator level
- โ Added
params_batch#last
method to retrieve last element after unparsing - All params keys are now strings