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