Sha256: f41289d849f26d6344ec23eb8d3cd993479395cc02403372b41b74ffaba21f00
Contents?: true
Size: 569 Bytes
Versions: 35
Compression:
Stored size: 569 Bytes
Contents
# frozen_string_literal: true module Kafka module Protocol class FindCoordinatorRequest def initialize(coordinator_key:, coordinator_type:) @coordinator_key = coordinator_key @coordinator_type = coordinator_type end def api_key FIND_COORDINATOR_API end def api_version 1 end def encode(encoder) encoder.write_string(@coordinator_key) encoder.write_int8(@coordinator_type) end def response_class FindCoordinatorResponse end end end end
Version data entries
35 entries across 35 versions & 4 rubygems