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