def connection
        broker = zk.registry["#{config.discovery_path}/druid:broker"].first
        raise DruidDB::ConnectionError, 'no druid brokers available' if broker.nil?
        zk.registry["#{config.discovery_path}/druid:broker"].rotate! # round-robin load balancing
        DruidDB::Connection.new(host: broker[:host], port: broker[:port])