lib/liquid/tracker/kafka_tracker.rb in liquid-ext-3.3.5 vs lib/liquid/tracker/kafka_tracker.rb in liquid-ext-3.3.6
- old
+ new
@@ -20,10 +20,10 @@
def event(topic, data)
@producer.send(KeyedMessage.new(topic, data))
rescue => e
# TODO: maybe fall back to FileTracker here
- $log.exception(e, "failed to log event=#{obj.inspect}")
+ $log.exception(e, "failed to log #{topic}=#{data.inspect}")
end
def shutdown
@producer.close if @producer
rescue Java::KafkaProducer::ProducerClosedException