Contents

module Kafka
  module Protocol
    class RequestMessage
      def initialize(api_key:, 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

2 entries across 2 versions & 1 rubygems

Version	Path
ruby-kafka-0.1.0.pre.alpha2	lib/kafka/protocol/request_message.rb
ruby-kafka-0.1.0.pre.alpha	lib/kafka/protocol/request_message.rb