class Kafka::Broker

def commit_offsets(**options) 

def commit_offsets(**options)
  request = Protocol::OffsetCommitRequest.new(**options)
  send_request(request)
end