Sha256: 1939772b36c7cc443b7208877d6c329c3d7d2837c53cbb89a69fce89a00245b5
Contents?: true
Size: 520 Bytes
Versions: 26
Compression:
Stored size: 520 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
HEARTBEAT_API
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
26 entries across 26 versions & 1 rubygems