Sha256: 4c678f9c809db9bc2d9f7a8bef2a793048acaafb4cab79e70a0c8a5fbba0abe9
Contents?: true
Size: 509 Bytes
Versions: 30
Compression:
Stored size: 509 Bytes
Contents
module Kafka
module Protocol
class HeartbeatRequest
def initialize(group_id:, generation_id:, member_id:)
@group_id = group_id
@generation_id = generation_id
@member_id = member_id
end
def api_key
12
end
def response_class
HeartbeatResponse
end
def encode(encoder)
encoder.write_string(@group_id)
encoder.write_int32(@generation_id)
encoder.write_string(@member_id)
end
end
end
end
Version data entries
30 entries across 30 versions & 1 rubygems