class Kafka::Protocol::FetchRequest

def initialize(max_wait_time:, min_bytes:, max_bytes:, topics:)

Parameters:
  • topics (Hash) --
  • min_bytes (Integer) --
  • max_wait_time (Integer) -- 
def initialize(max_wait_time:, min_bytes:, max_bytes:, topics:)
  @replica_id = REPLICA_ID
  @max_wait_time = max_wait_time
  @min_bytes = min_bytes
  @max_bytes = max_bytes
  @topics = topics
end