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