Sha256: 384926355593975a9b4657b56ebfcb1b8e2896df50b1e8208a7e36a77e76e215
Contents?: true
Size: 632 Bytes
Versions: 49
Compression:
Stored size: 632 Bytes
Contents
# frozen_string_literal: true
module Kafka
module Protocol
class RequestMessage
API_VERSION = 0
def initialize(api_key:, api_version: API_VERSION, correlation_id:, client_id:, request:)
@api_key = api_key
@api_version = api_version
@correlation_id = correlation_id
@client_id = client_id
@request = request
end
def encode(encoder)
encoder.write_int16(@api_key)
encoder.write_int16(@api_version)
encoder.write_int32(@correlation_id)
encoder.write_string(@client_id)
@request.encode(encoder)
end
end
end
end
Version data entries
49 entries across 49 versions & 4 rubygems