Method: Kafka::FetchOperation#initialize

Defined in:
lib/kafka/fetch_operation.rb

#initialize(cluster:, logger:, min_bytes: 1, max_bytes: 10485760, max_wait_time: 5) ⇒ FetchOperation

Returns a new instance of FetchOperation.



24
25
26
27
28
29
30
31
32
33
34
35
 
# File 'lib/kafka/fetch_operation.rb', line 24

def initialize(cluster:, logger:, min_bytes: 1, max_bytes: 10485760, max_wait_time: 5)
  @cluster = cluster
  @logger = TaggedLogger.new(logger)
  @min_bytes = min_bytes
  @max_bytes = max_bytes
  @max_wait_time = max_wait_time
  @topics = {}

  @offset_resolver = Kafka::FetchedOffsetResolver.new(
    logger: logger
  )
end