Raise an exception if no seed brokers are configured

zendesk · Feb 10, 2016 · 142ee01 · 142ee01
1 parent 5b53d6c
commit 142ee01
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/lib/kafka/broker_pool.rb b/lib/kafka/broker_pool.rb
@@ -18,6 +18,10 @@ class BrokerPool
     # @param connect_timeout [Integer, nil] see {Connection#initialize}.
     # @param socket_timeout [Integer, nil] see {Connection#initialize}.
     def initialize(seed_brokers:, client_id:, logger:, connect_timeout: nil, socket_timeout: nil)
+      if seed_brokers.empty?
+        raise ArgumentError, "At least one seed broker must be configured"
+      end
+
       @client_id = client_id
       @logger = logger
       @connect_timeout = connect_timeout