kafka.rb in franz-2.1.12

- old
+ new

@@ -80,9 +80,14 @@
 
         @thread = Thread.new do
           until @stop
             event = opts[:input].shift
 
+            unless opts[:tags].empty?
+              event['tags'] ||= []
+              event['tags']  += opts[:tags]
+            end
+
             log.trace \
               event: 'publish',
               raw: event
 
             payload = JSON::generate(event)
\ No newline at end of file