class Kafka::Retryable::MessageDispatcher::Kafka

Public Class Methods

new(topic, message) click to toggle source
# File lib/kafka/retryable/message_dispatcher/kafka.rb, line 4
def initialize(topic, message)
  @topic = topic
  @message = message
end

Public Instance Methods

perform() click to toggle source
# File lib/kafka/retryable/message_dispatcher/kafka.rb, line 9
def perform
  WaterDrop::SyncProducer.call(
    @message,
    { topic: @topic.to_s }
  )
end