Method: Redborder::KafkaNotifier.start

Defined in:
lib/kafka_notifier.rb

.start ⇒ Object 



36
37
38
39
40
41
42
43
44
 
# File 'lib/kafka_notifier.rb', line 36

def self.start
  self.producer = Poseidon::Producer.new(
    config[:brokers], config[:client_id], type: :sync,
    required_acks: 1, partitioner: partitioner
  )

  self.message_queue = MessageQueue.new(500, 1)
  create_producer_thread
end