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

PRODUCE_API_KEY = 
0
TOPIC_METADATA_API_KEY = 
3
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

.handle_error(error_code) ⇒ Object 



27
28
29
30
31
32
33
34
35
 
# File 'lib/kafka/protocol.rb', line 27

def self.handle_error(error_code)
  if error_code == 0
    # No errors, yay!
  elsif error = ERRORS[error_code]
    raise error
  else
    raise UnknownError, "Unknown error with code #{error_code}"
  end
end