Class: Fake::Kafka::Producer

Inherits:
Object
  • Object
show all
Defined in:
lib/fake/kafka/producer.rb

Instance Method Summary collapse

Constructor Details

#initialize(kafka) ⇒ Producer

Returns a new instance of Producer.



2
3
4
5
 
# File 'lib/fake/kafka/producer.rb', line 2

def initialize(kafka)
  @kafka = kafka
  @buffer = []
end

Instance Method Details

#deliver_messages ⇒ Object 



11
12
13
14
15
 
# File 'lib/fake/kafka/producer.rb', line 11

def deliver_messages
  @buffer.each do |value, **options|
    @kafka.deliver_message(value.to_s, **options)
  end
end

#produce(value, **options) ⇒ Object 



7
8
9
 
# File 'lib/fake/kafka/producer.rb', line 7

def produce(value, **options)
  @buffer << [value, options]
end

#shutdown ⇒ Object

github.com/zendesk/ruby-kafka/blob/v1.0.0/lib/kafka/producer.rb#L285



18
19
20
 
# File 'lib/fake/kafka/producer.rb', line 18

def shutdown
  # NOOP
end