class Kafka::Broker

def create_partitions(**options) 

def create_partitions(**options)
  request = Protocol::CreatePartitionsRequest.new(**options)
  send_request(request)
end