Exception: Kafka::ProtocolError
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