Class: Kafka::Protocol::TxnOffsetCommitResponse
- Inherits:
-
Object
- Object
- Kafka::Protocol::TxnOffsetCommitResponse
- Defined in:
- lib/kafka/protocol/txn_offset_commit_response.rb
Instance Attribute Summary collapse
-
#error_code ⇒ Object
readonly
Returns the value of attribute error_code.
Class Method Summary collapse
Instance Method Summary collapse
-
#initialize(error_code:) ⇒ TxnOffsetCommitResponse
constructor
A new instance of TxnOffsetCommitResponse.
Constructor Details
#initialize(error_code:) ⇒ TxnOffsetCommitResponse
Returns a new instance of TxnOffsetCommitResponse.
7 8 9 |
# File 'lib/kafka/protocol/txn_offset_commit_response.rb', line 7 def initialize(error_code:) @error_code = error_code end |
Instance Attribute Details
#error_code ⇒ Object (readonly)
Returns the value of attribute error_code.
5 6 7 |
# File 'lib/kafka/protocol/txn_offset_commit_response.rb', line 5 def error_code @error_code end |
Class Method Details
.decode(decoder) ⇒ Object
11 12 13 14 15 |
# File 'lib/kafka/protocol/txn_offset_commit_response.rb', line 11 def self.decode(decoder) _throttle_time_ms = decoder.int32 error_code = decoder.int16 new(error_code: error_code) end |