Sha256: 5c882647f314c7a8bde4a7cfbc15d10fe7e87e2d6eb615b562b384790c0d7d33
Contents?: true
Size: 601 Bytes
Versions: 69
Compression:
Stored size: 601 Bytes
Contents
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
69 entries across 69 versions & 1 rubygems