Class: Kafka::Protocol::DeleteTopicsRequest

7
8
9

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

11
12
13

# File 'lib/kafka/protocol/delete_topics_request.rb', line 11
def api_key
 DELETE_TOPICS_API 
end

15
16
17

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

23
24
25
26
27
28
29

# File 'lib/kafka/protocol/delete_topics_request.rb', line 23
def encode(encoder)
 encoder.write_array(@topics) do |topic|
 encoder.write_string(topic)
 end
 # Timeout is in ms.
 encoder.write_int32(@timeout * 1000)
end

19
20
21

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