lib/liquid/tracker/kafka_tracker.rb in liquid-ext-3.0.0 vs lib/liquid/tracker/kafka_tracker.rb in liquid-ext-3.1.0

@@ -22,11 +22,11 @@
       # TODO: async is fire and forget. we might want to handle
       # QueueFullExceptions later
       false
     end
 
-    def event(obj, topic)
-      @producer.send(KeyedMessage.new(topic, @serializer.dump(obj)))
+    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}")
     end