Class: TransactionalOutbox::Producer::Adapters::Kafka

Inherits:
Base
  • Object
show all
Defined in:
lib/transactional_outbox/producer/adapters/kafka.rb

Instance Method Summary collapse

Methods included from InstanceMethods

#initialize

Instance Method Details

#close ⇒ Object 



13
 
# File 'lib/transactional_outbox/producer/adapters/kafka.rb', line 13

def close = client.close

#produce_batch(topic, events) ⇒ Object 



7
8
9
10
11
 
# File 'lib/transactional_outbox/producer/adapters/kafka.rb', line 7

def produce_batch(topic, events)
  buffer_events(topic, events)

  producer.deliver_messages
end