Class: BPS::Publisher::Kafka::Topic

Inherits:

Abstract::Topic

• Object
• Abstract::Topic
• BPS::Publisher::Kafka::Topic

Defined in:

lib/bps/publisher/kafka.rb

Direct Known Subclasses

BPS::Publisher::KafkaAsync::Topic

Instance Method Summary

• #flush ⇒ Object
• #initialize(producer, topic) ⇒ Topic constructor

  A new instance of Topic.

• #publish(message, **opts) ⇒ Object

Constructor Details

#initialize(producer, topic) ⇒ Topic

Returns a new instance of Topic.

# File 'lib/bps/publisher/kafka.rb', line 7

def initialize(producer, topic)
  super()

  @producer = producer
  @topic = topic
end

Instance Method Details

#flush ⇒ Object

# File 'lib/bps/publisher/kafka.rb', line 19

def flush(**)
  @producer.deliver_messages
end

#publish(message, **opts) ⇒ Object

# File 'lib/bps/publisher/kafka.rb', line 14

def publish(message, **opts)
  @producer.produce(message, **opts, topic: @topic)
  after_publish
end