class Kafka::Protocol::HeartbeatRequest
Public Class Methods
new(group_id:, generation_id:, member_id:)
click to toggle source
# File lib/kafka/protocol/heartbeat_request.rb, line 6 def initialize(group_id:, generation_id:, member_id:) @group_id = group_id @generation_id = generation_id @member_id = member_id end
Public Instance Methods
api_key()
click to toggle source
# File lib/kafka/protocol/heartbeat_request.rb, line 12 def api_key HEARTBEAT_API end
encode(encoder)
click to toggle source
# File lib/kafka/protocol/heartbeat_request.rb, line 20 def encode(encoder) encoder.write_string(@group_id) encoder.write_int32(@generation_id) encoder.write_string(@member_id) end
response_class()
click to toggle source
# File lib/kafka/protocol/heartbeat_request.rb, line 16 def response_class HeartbeatResponse end