class Kafka::Producer
Public Instance Methods
produce2(value, topic:)
click to toggle source
# File lib/fluent/plugin/kafka_producer_ext.rb, line 10 def produce2(value, topic:) create_time = Time.now message = PendingMessage.new( value, nil, topic, nil, nil, create_time ) @target_topics.add(topic) @pending_message_queue.write(message) nil end