lib/kafkr/log.rb in kafkr-0.18.0 vs lib/kafkr/log.rb in kafkr-0.018.1
- old
+ new
@@ -25,10 +25,10 @@
loop do
client = @server.accept
client_ip = client.peeraddr[3]
unless whitelisted?(client_ip)
- puts "Connection from non-whitelisted IP: #{client_ip}. Ignored."
+ Kafkr.log "Connection from non-whitelisted IP: #{client_ip}. Ignored."
client.close
next
end
@broker.add_subscriber(client)