lib/kafka/connection.rb in ruby-kafka-0.4.3 vs lib/kafka/connection.rb in ruby-kafka-0.4.4

@@ -57,9 +57,13 @@
       @socket_timeout = socket_timeout || SOCKET_TIMEOUT
       @ssl_context = ssl_context
       @sasl_authenticator = sasl_authenticator
     end
 
+    def address_match?(host, port)
+      @host == host && @port == port
+    end
+
     def to_s
       "#{@host}:#{@port}"
     end
 
     def open?