class MessageBrokerAdapter::Kafka
Adapter implements Apache Kafka
Public Class Methods
publish(topic, payload, options = {})
click to toggle source
# File lib/messaging_adapter/adapters/kafka.rb, line 6 def self.publish(topic, payload, options = {}) puts "Not implemented yet!! publish{#{topic} [#{payload}]}" puts options end
subscribe(topic, options = {})
click to toggle source
# File lib/messaging_adapter/adapters/kafka.rb, line 11 def self.subscribe(topic, options = {}) puts "Not implemented yet!! subscribe{#{topic}}" puts options end