class BPS::Publisher::Kafka::Topic

Public Class Methods

new(producer, topic) click to toggle source
Calls superclass method
# File lib/bps/publisher/kafka.rb, line 7
def initialize(producer, topic)
  super()

  @producer = producer
  @topic = topic
end

Public Instance Methods

flush(**) click to toggle source
# File lib/bps/publisher/kafka.rb, line 19
def flush(**)
  @producer.deliver_messages
end
publish(message, **opts) click to toggle source
# File lib/bps/publisher/kafka.rb, line 14
def publish(message, **opts)
  @producer.produce(message, **opts, topic: @topic)
  after_publish
end

Protected Instance Methods

after_publish() click to toggle source
# File lib/bps/publisher/kafka.rb, line 25
def after_publish
  @producer.deliver_messages
  nil
end