Sha256: e7306b4dfa7e494186736db7e9bd3c813efc87c51a5552d99b61489e2dd1c1b6
Contents?: true
Size: 340 Bytes
Versions: 30
Compression:
Stored size: 340 Bytes
Contents
module Kafka
module Protocol
class GroupCoordinatorRequest
def initialize(group_id:)
@group_id = group_id
end
def api_key
10
end
def encode(encoder)
encoder.write_string(@group_id)
end
def response_class
GroupCoordinatorResponse
end
end
end
end
Version data entries
30 entries across 30 versions & 1 rubygems