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