Sha256: 624e3edcca15102e4a2a600cfb60f0affbc904168aa92411b488e4fbf520bb08
Contents?: true
Size: 551 Bytes
Versions: 49
Compression:
Stored size: 551 Bytes
Contents
# frozen_string_literal: true
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
49 entries across 49 versions & 4 rubygems