Class: EventMachine::Kafka::ProducerRequest

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

Instance Method Summary collapse

Constructor Details

#initialize(topic, partition, messages) ⇒ ProducerRequest

Returns a new instance of ProducerRequest.



4
5
6
 
# File 'lib/em-kafka/producer_request.rb', line 4

def initialize(topic, partition, messages)
  @topic, @partition, @messages = topic, partition, messages
end

Instance Method Details

#encode ⇒ Object 



8
9
10
11
12
13
14
15
16
 
# File 'lib/em-kafka/producer_request.rb', line 8

def encode
  data = "\x00\x00" +
         [@topic.length].pack("n") +
         @topic +
         [@partition].pack("N") +
         encode_messages(@messages)

  [data.length].pack("N") + data
end