Class: Kafka::Protocol::FetchResponse::FetchedPartition
- Inherits:
-
Object
- Object
- Kafka::Protocol::FetchResponse::FetchedPartition
- Defined in:
- lib/kafka/protocol/fetch_response.rb
Instance Attribute Summary collapse
-
#aborted_transactions ⇒ Object
readonly
Returns the value of attribute aborted_transactions.
-
#error_code ⇒ Object
readonly
Returns the value of attribute error_code.
-
#highwater_mark_offset ⇒ Object
readonly
Returns the value of attribute highwater_mark_offset.
-
#last_stable_offset ⇒ Object
readonly
Returns the value of attribute last_stable_offset.
-
#messages ⇒ Object
readonly
Returns the value of attribute messages.
-
#partition ⇒ Object
readonly
Returns the value of attribute partition.
Instance Method Summary collapse
-
#initialize(partition:, error_code:, highwater_mark_offset:, last_stable_offset:, aborted_transactions:, messages:) ⇒ FetchedPartition
constructor
A new instance of FetchedPartition.
Constructor Details
#initialize(partition:, error_code:, highwater_mark_offset:, last_stable_offset:, aborted_transactions:, messages:) ⇒ FetchedPartition
Returns a new instance of FetchedPartition.
34 35 36 37 38 39 40 41
# File 'lib/kafka/protocol/fetch_response.rb', line 34 def initialize(partition:, error_code:, highwater_mark_offset:, last_stable_offset:, aborted_transactions:, messages:) @partition = partition @error_code = error_code @highwater_mark_offset = highwater_mark_offset @messages = messages @last_stable_offset = last_stable_offset @aborted_transactions = aborted_transactions end
Instance Attribute Details
#aborted_transactions ⇒ Object (readonly)
Returns the value of attribute aborted_transactions.
32 33 34
# File 'lib/kafka/protocol/fetch_response.rb', line 32 def aborted_transactions @aborted_transactions end
#error_code ⇒ Object (readonly)
Returns the value of attribute error_code.
31 32 33
# File 'lib/kafka/protocol/fetch_response.rb', line 31 def error_code @error_code end
#highwater_mark_offset ⇒ Object (readonly)
Returns the value of attribute highwater_mark_offset.
32 33 34
# File 'lib/kafka/protocol/fetch_response.rb', line 32 def highwater_mark_offset @highwater_mark_offset end
#last_stable_offset ⇒ Object (readonly)
Returns the value of attribute last_stable_offset.
32 33 34
# File 'lib/kafka/protocol/fetch_response.rb', line 32 def last_stable_offset @last_stable_offset end
#messages ⇒ Object (readonly)
Returns the value of attribute messages.
32 33 34
# File 'lib/kafka/protocol/fetch_response.rb', line 32 def messages @messages end
#partition ⇒ Object (readonly)
Returns the value of attribute partition.
31 32 33
# File 'lib/kafka/protocol/fetch_response.rb', line 31 def partition @partition end