Sha256: 69ede56cc5820f192b3f8b16cbd10f2ebe6f5fc72b2e4fd98c9c3a7a36480415
Contents?: true
Size: 486 Bytes
Versions: 46
Compression:
Stored size: 486 Bytes
Contents
# frozen_string_literal: true
module Kafka
module Protocol
class DescribeGroupsRequest
def initialize(group_ids:)
@group_ids = group_ids
end
def api_key
DESCRIBE_GROUPS_API
end
def api_version
0
end
def response_class
Protocol::DescribeGroupsResponse
end
def encode(encoder)
encoder.write_array(@group_ids) { |group_id| encoder.write_string(group_id) }
end
end
end
end
Version data entries
46 entries across 46 versions & 4 rubygems