lib/rdkafka/config.rb in rdkafka-0.3.0 vs lib/rdkafka/config.rb in rdkafka-0.3.1
- old
+ new
@@ -134,10 +134,10 @@
config,
error_buffer,
256
)
- if handle.nil?
+ if handle.null?
raise ClientCreationError.new(error_buffer.read_string)
end
# Redirect log to handle's queue
Rdkafka::Bindings.rd_kafka_set_log_queue(