class Kafka::Protocol::InitProducerIDRequest
Public Class Methods
new(transactional_id: nil, transactional_timeout:)
click to toggle source
# File lib/kafka/protocol/init_producer_id_request.rb, line 6 def initialize(transactional_id: nil, transactional_timeout:) @transactional_id = transactional_id @transactional_timeout = transactional_timeout end
Public Instance Methods
api_key()
click to toggle source
# File lib/kafka/protocol/init_producer_id_request.rb, line 11 def api_key INIT_PRODUCER_ID_API end
encode(encoder)
click to toggle source
# File lib/kafka/protocol/init_producer_id_request.rb, line 19 def encode(encoder) encoder.write_string(@transactional_id) # Timeout is in ms unit encoder.write_int32(@transactional_timeout * 1000) end
response_class()
click to toggle source
# File lib/kafka/protocol/init_producer_id_request.rb, line 15 def response_class InitProducerIDResponse end