lib/racecar/ctl.rb in racecar-0.3.0.beta1 vs lib/racecar/ctl.rb in racecar-0.3.0
- old
+ new
@@ -58,9 +58,9 @@
socket_timeout: Racecar.config.socket_timeout,
)
kafka.deliver_message(message.value, key: message.key, topic: message.topic)
- puts "=> Delivered message to Kafka cluster"
+ $stderr.puts "=> Delivered message to Kafka cluster"
end
end
end