Exception: Kafka::ProtocolError
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, ClusterAuthorizationFailed, CoordinatorNotAvailable, CorruptMessage, GroupAuthorizationFailed, 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, TopicAuthorizationFailed, UnknownError, UnknownMemberId, UnknownTopicOrPartition, UnsupportedSaslMechanism, UnsupportedVersion