Module: Kafka::Protocol
- Defined in:
- lib/kafka/protocol.rb,
lib/kafka/protocol/decoder.rb,
lib/kafka/protocol/encoder.rb,
lib/kafka/protocol/message.rb,
lib/kafka/protocol/produce_request.rb,
lib/kafka/protocol/request_message.rb,
lib/kafka/protocol/produce_response.rb,
lib/kafka/protocol/metadata_response.rb,
lib/kafka/protocol/topic_metadata_request.rb
Defined Under Namespace
Classes: Decoder, Encoder, Message, MetadataResponse, ProduceRequest, ProduceResponse, RequestMessage, TopicMetadataRequest
Constant Summary
collapse
- APIS =
{
0 => :produce,
3 => :topic_metadata,
}
- ERRORS =
{
-1 => UnknownError,
1 => OffsetOutOfRange,
2 => CorruptMessage,
3 => UnknownTopicOrPartition,
4 => InvalidMessageSize,
5 => LeaderNotAvailable,
6 => NotLeaderForPartition,
7 => RequestTimedOut,
8 => BrokerNotAvailable,
9 => ReplicaNotAvailable,
10 => MessageSizeTooLarge,
12 => OffsetMetadataTooLarge,
17 => InvalidTopic,
18 => RecordListTooLarge,
19 => NotEnoughReplicas,
20 => NotEnoughReplicasAfterAppend,
21 => InvalidRequiredAcks,
}
Class Method Summary
collapse
Class Method Details
.api_name(api_key) ⇒ Object
38
39
40
|
# File 'lib/kafka/protocol.rb', line 38
def self.api_name(api_key)
APIS.fetch(api_key, :unknown)
end
|
.handle_error(error_code) ⇒ Object
28
29
30
31
32
33
34
35
36
|
# File 'lib/kafka/protocol.rb', line 28
def self.handle_error(error_code)
if error_code == 0
elsif error = ERRORS[error_code]
raise error
else
raise UnknownError, "Unknown error with code #{error_code}"
end
end
|