Exception: Kafka::ProtocolError

Inherits:

Error

• Object
• StandardError
• Error
• Kafka::ProtocolError

Defined in:

lib/kafka.rb

Overview

Subclasses of this exception class map to an error code described in the Kafka protocol specification.

See https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol

Direct Known Subclasses

BrokerNotAvailable, ClusterAuthorizationCode, CorruptMessage, GroupAuthorizationCode, GroupCoordinatorNotAvailable, IllegalGeneration, InvalidCommitOffsetSize, InvalidConfig, InvalidMessageSize, InvalidPartitions, InvalidReplicaAssignment, InvalidReplicationFactor, InvalidRequest, InvalidRequiredAcks, InvalidSaslState, InvalidSessionTimeout, InvalidTimestamp, InvalidTopic, LeaderNotAvailable, MessageSizeTooLarge, NotController, NotCoordinatorForGroup, NotEnoughReplicas, NotEnoughReplicasAfterAppend, NotLeaderForPartition, OffsetMetadataTooLarge, OffsetOutOfRange, RebalanceInProgress, RecordListTooLarge, ReplicaNotAvailable, RequestTimedOut, TopicAlreadyExists, TopicAuthorizationCode, UnknownError, UnknownMemberId, UnknownTopicOrPartition, UnsupportedSaslMechanism, UnsupportedVersion