Class: Kafka::Protocol::DescribeConfigsRequest

7
8
9

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

11
12
13

# File 'lib/kafka/protocol/describe_configs_request.rb', line 11
def api_key
 DESCRIBE_CONFIGS_API 
end

15
16
17

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

23
24
25
26
27
28
29
30
31

# File 'lib/kafka/protocol/describe_configs_request.rb', line 23
def encode(encoder)
 encoder.write_array(@resources) do |type, name, configs|
 encoder.write_int8(type)
 encoder.write_string(name)
 encoder.write_array(configs) do |config|
 encoder.write_string(config)
 end
 end
end

19
20
21

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