class Kafka::Cluster

def alter_topic(name, configs = {})
  options = {
    resources: [[Kafka::Protocol::RESOURCE_TYPE_TOPIC, name, configs]]
  }
  broker = controller_broker
  @logger.info "Altering the config for topic `#{name}` using controller broker #{broker}"
  response = broker.alter_configs(**options)
  response.resources.each do |resource|
    Protocol.handle_error(resource.error_code, resource.error_message)
  end
  nil
end