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