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