class Kafka::Protocol::ListOffsetRequest


MaxNumberOfOffsets => int32
Time => int64
Partition => int32
TopicName => string
ReplicaId => int32
OffsetRequest => ReplicaId [TopicName [Partition Time MaxNumberOfOffsets]]
## API Specification
A request to list the available offsets for a set of topics/partitions.

def api_key 

def api_key
  2
end

def encode(encoder) 

def encode(encoder)
  encoder.write_int32(@replica_id)
  encoder.write_array(@topics) do |topic, partitions|
    encoder.write_string(topic)
    encoder.write_array(partitions) do |partition|
      encoder.write_int32(partition.fetch(:partition))
      encoder.write_int64(partition.fetch(:time))
      encoder.write_int32(partition.fetch(:max_offsets))
    end
  end
end

def initialize(topics:)

Parameters:
  • topics (Hash) -- 
def initialize(topics:)
  @replica_id = REPLICA_ID
  @topics = topics
end