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. https://kafka.apache.org/protocol#protocol_error_codes

Direct Known Subclasses

BrokerNotAvailable, ClusterAuthorizationFailed, CoordinatorLoadInProgress, CoordinatorNotAvailable, CorruptMessage, GroupAuthorizationFailed, IllegalGeneration, InconsistentGroupProtocol, InvalidCommitOffsetSize, InvalidConfig, InvalidGroupId, InvalidMessageSize, InvalidPartitions, InvalidReplicaAssignment, InvalidReplicationFactor, InvalidRequest, InvalidRequiredAcks, InvalidSaslState, InvalidSessionTimeout, InvalidTimestamp, InvalidTopic, LeaderNotAvailable, MessageSizeTooLarge, NetworkException, NotController, NotCoordinatorForGroup, NotEnoughReplicas, NotEnoughReplicasAfterAppend, NotLeaderForPartition, OffsetMetadataTooLarge, OffsetOutOfRange, PolicyViolation, RebalanceInProgress, RecordListTooLarge, ReplicaNotAvailable, RequestTimedOut, StaleControllerEpoch, TopicAlreadyExists, TopicAuthorizationFailed, UnknownError, UnknownMemberId, UnknownTopicOrPartition, UnsupportedForMessageFormat, UnsupportedSaslMechanism, UnsupportedVersion