class Kafka::Protocol::InitProducerIDResponse
Attributes
error_code[R]
producer_epoch[R]
producer_id[R]
Public Class Methods
decode(decoder)
click to toggle source
# File lib/kafka/protocol/init_producer_id_response.rb, line 14 def self.decode(decoder) _throttle_time_ms = decoder.int32 error_code = decoder.int16 producer_id = decoder.int64 producer_epoch = decoder.int16 new( error_code: error_code, producer_id: producer_id, producer_epoch: producer_epoch ) end
new(error_code:, producer_id:, producer_epoch:)
click to toggle source
# File lib/kafka/protocol/init_producer_id_response.rb, line 8 def initialize(error_code:, producer_id:, producer_epoch:) @error_code = error_code @producer_id = producer_id @producer_epoch = producer_epoch end