Class: Kafka::Protocol::DescribeGroupsRequest

6
7
8

# File 'lib/kafka/protocol/describe_groups_request.rb', line 6
def initialize(group_ids:)
 @group_ids = group_ids
end

10
11
12

# File 'lib/kafka/protocol/describe_groups_request.rb', line 10
def api_key
 DESCRIBE_GROUPS_API 
end

14
15
16

# File 'lib/kafka/protocol/describe_groups_request.rb', line 14
def api_version
 0
end

22
23
24

# File 'lib/kafka/protocol/describe_groups_request.rb', line 22
def encode(encoder)
 encoder.write_array(@group_ids) { |group_id| encoder.write_string(group_id) }
end

18
19
20

# File 'lib/kafka/protocol/describe_groups_request.rb', line 18
def response_class
 Protocol ::DescribeGroupsResponse 
end