Class: Kafka::Protocol::CreatePartitionsRequest

7
8
9

# File 'lib/kafka/protocol/create_partitions_request.rb', line 7
def initialize(topics:, timeout:)
 @topics, @timeout = topics, timeout
end

11
12
13

# File 'lib/kafka/protocol/create_partitions_request.rb', line 11
def api_key
 CREATE_PARTITIONS_API 
end

15
16
17

# File 'lib/kafka/protocol/create_partitions_request.rb', line 15
def api_version
 0
end

23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

# File 'lib/kafka/protocol/create_partitions_request.rb', line 23
def encode(encoder)
 encoder.write_array(@topics) do |topic, count, assignments|
 encoder.write_string(topic)
 encoder.write_int32(count)
 encoder.write_array(assignments) do |assignment|
 encoder.write_array(assignment) do |broker|
 encoder.write_int32(broker)
 end
 end
 end
 # Timeout is in ms.
 encoder.write_int32(@timeout * 1000)
 # validate_only. There isn't any use case for this in real life. So
 # let's ignore it for now
 encoder.write_boolean(false)
end

19
20
21

# File 'lib/kafka/protocol/create_partitions_request.rb', line 19
def response_class
 Protocol ::CreatePartitionsResponse 
end