lib/karafka/params/params_batch.rb in karafka-0.6.0.rc2 vs lib/karafka/params/params_batch.rb in karafka-1.0.0.rc1

- old
+ new

@@ -2,16 +2,11 @@ module Karafka module Params # Params batch represents a set of messages received from Kafka. # @note Params internally are lazy loaded before first use. That way we can skip parsing - # process if we have before_enqueue that rejects some incoming messages without using params - # It can be also used when handling really heavy data (in terms of parsing). Without direct - # usage outside of worker scope, it will pass raw data into sidekiq, so we won't use Karafka - # working time to parse this data. It will happen only in the worker (where it can take time) - # that way Karafka will be able to process data really quickly. On the other hand, if we - # decide to use params somewhere before it hits worker logic, it won't parse it again in - # the worker - it will use already loaded data and pass it to Redis + # process if we have after_received that rejects some incoming messages without using params + # It can be also used when handling really heavy data (in terms of parsing). class ParamsBatch include Enumerable # Builds up a params batch based on raw kafka messages # @param messages_batch [Array<Kafka::FetchedMessage>] messages batch