class Kafka::Protocol::FindCoordinatorRequest

Public Class Methods

new(coordinator_key:, coordinator_type:) click to toggle source
# File lib/kafka/protocol/find_coordinator_request.rb, line 6
def initialize(coordinator_key:, coordinator_type:)
  @coordinator_key  = coordinator_key
  @coordinator_type = coordinator_type
end

Public Instance Methods

api_key() click to toggle source
# File lib/kafka/protocol/find_coordinator_request.rb, line 11
def api_key
  FIND_COORDINATOR_API
end
api_version() click to toggle source
# File lib/kafka/protocol/find_coordinator_request.rb, line 15
def api_version
  1
end
encode(encoder) click to toggle source
# File lib/kafka/protocol/find_coordinator_request.rb, line 19
def encode(encoder)
  encoder.write_string(@coordinator_key)
  encoder.write_int8(@coordinator_type)
end
response_class() click to toggle source
# File lib/kafka/protocol/find_coordinator_request.rb, line 24
def response_class
  FindCoordinatorResponse
end