Class: Kafka::Protocol::FetchResponse
- Inherits:
-
Object
- Object
- Kafka::Protocol::FetchResponse
- Defined in:
- lib/kafka/protocol/fetch_response.rb
Overview
A response to a fetch request.
API Specification
FetchResponse => [TopicName [Partition ErrorCode HighwaterMarkOffset MessageSetSize MessageSet]]
TopicName => string
Partition => int32
ErrorCode => int16
HighwaterMarkOffset => int64
MessageSetSize => int32
Defined Under Namespace
Classes: FetchedPartition, FetchedTopic
Instance Attribute Summary collapse
-
#topics ⇒ Object
readonly
Returns the value of attribute topics.
Class Method Summary collapse
Instance Method Summary collapse
-
#initialize(topics: [], throttle_time_ms: 0) ⇒ FetchResponse
constructor
A new instance of FetchResponse.
Constructor Details
#initialize(topics: [], throttle_time_ms: 0) ⇒ FetchResponse
Returns a new instance of FetchResponse.
41 42 43 44 |
# File 'lib/kafka/protocol/fetch_response.rb', line 41 def initialize(topics: [], throttle_time_ms: 0) @topics = topics @throttle_time_ms = throttle_time_ms end |
Instance Attribute Details
#topics ⇒ Object (readonly)
Returns the value of attribute topics.
39 40 41 |
# File 'lib/kafka/protocol/fetch_response.rb', line 39 def topics @topics end |
Class Method Details
.decode(decoder) ⇒ Object
46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 |
# File 'lib/kafka/protocol/fetch_response.rb', line 46 def self.decode(decoder) throttle_time_ms = decoder.int32 topics = decoder.array do topic_name = decoder.string partitions = decoder.array do partition = decoder.int32 error_code = decoder.int16 highwater_mark_offset = decoder.int64 = Decoder.from_string(decoder.bytes) = MessageSet.decode() FetchedPartition.new( partition: partition, error_code: error_code, highwater_mark_offset: highwater_mark_offset, messages: ., ) end FetchedTopic.new( name: topic_name, partitions: partitions, ) end new(topics: topics, throttle_time_ms: throttle_time_ms) end |