lib/kafka/connection.rb in ruby-kafka-0.5.1.beta1 vs lib/kafka/connection.rb in ruby-kafka-0.5.1.beta2

- old
+ new

@@ -87,13 +87,13 @@ api: api_name, request_size: 0, response_size: 0, } + raise IdleConnection if idle? + @instrumenter.instrument("request.connection", notification) do open unless open? - - raise IdleConnection if idle? @correlation_id += 1 @logger.debug "Sending #{api_name} API request #{@correlation_id} to #{to_s}"