Class: Kafka::Protocol::FetchResponse::FetchedPartition
- Inherits:
-
Object
- Object
- Kafka::Protocol::FetchResponse::FetchedPartition
- Defined in:
- lib/kafka/protocol/fetch_response.rb
Instance Attribute Summary collapse
-
#error_code ⇒ Object
readonly
Returns the value of attribute error_code.
-
#highwater_mark_offset ⇒ Object
readonly
Returns the value of attribute highwater_mark_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:, messages:) ⇒ FetchedPartition
constructor
A new instance of FetchedPartition.
Constructor Details
#initialize(partition:, error_code:, highwater_mark_offset:, messages:) ⇒ FetchedPartition
Returns a new instance of FetchedPartition.
22 23 24 25 26 27 |
# File 'lib/kafka/protocol/fetch_response.rb', line 22 def initialize(partition:, error_code:, highwater_mark_offset:, messages:) @partition = partition @error_code = error_code @highwater_mark_offset = highwater_mark_offset @messages = end |
Instance Attribute Details
#error_code ⇒ Object (readonly)
Returns the value of attribute error_code.
19 20 21 |
# File 'lib/kafka/protocol/fetch_response.rb', line 19 def error_code @error_code end |
#highwater_mark_offset ⇒ Object (readonly)
Returns the value of attribute highwater_mark_offset.
20 21 22 |
# File 'lib/kafka/protocol/fetch_response.rb', line 20 def highwater_mark_offset @highwater_mark_offset end |
#messages ⇒ Object (readonly)
Returns the value of attribute messages.
20 21 22 |
# File 'lib/kafka/protocol/fetch_response.rb', line 20 def @messages end |
#partition ⇒ Object (readonly)
Returns the value of attribute partition.
19 20 21 |
# File 'lib/kafka/protocol/fetch_response.rb', line 19 def partition @partition end |