Class: Kafka::ProducerRequest

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

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(topic, messages, options = {}) ⇒ ProducerRequest

Returns a new instance of ProducerRequest.



20
21
22
23
24
 
# File 'lib/kafka/producer_request.rb', line 20

def initialize(topic, messages, options={})
  self.topic = topic
  self.partition = options[:partition] || 0
  self.messages = Array(messages)
end

Instance Attribute Details

#messages ⇒ Object

Returns the value of attribute messages.



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

def messages
  @messages
end

#partition ⇒ Object

Returns the value of attribute partition.



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

def partition
  @partition
end

#topic ⇒ Object

Returns the value of attribute topic.



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

def topic
  @topic
end