Serialized Form

Package org.apache.kafka.clients.consumer

Class org.apache.kafka.clients.consumer.CommitFailedException extends KafkaException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.clients.consumer.InvalidOffsetException extends KafkaException implements Serializable

Class org.apache.kafka.clients.consumer.LogTruncationException extends OffsetOutOfRangeException implements Serializable

Serialized Fields

divergentOffsets

Map<K,V> divergentOffsets

Class org.apache.kafka.clients.consumer.NoOffsetForPartitionException extends InvalidOffsetException implements Serializable

serialVersionUID:

1L

Serialized Fields

partitions

Set<E> partitions

Class org.apache.kafka.clients.consumer.OffsetAndMetadata extends Object implements Serializable

serialVersionUID:

2019555404968089681L

Serialized Fields

offset

long offset

metadata

String metadata

leaderEpoch

Integer leaderEpoch

Class org.apache.kafka.clients.consumer.OffsetOutOfRangeException extends InvalidOffsetException implements Serializable

serialVersionUID:

1L

Serialized Fields

offsetOutOfRangePartitions

Map<K,V> offsetOutOfRangePartitions

Class org.apache.kafka.clients.consumer.RetriableCommitFailedException extends RetriableException implements Serializable

serialVersionUID:

1L

Package org.apache.kafka.clients.producer

Class org.apache.kafka.clients.producer.BufferExhaustedException extends TimeoutException implements Serializable

serialVersionUID:

1L

Package org.apache.kafka.common

Class org.apache.kafka.common.InvalidRecordException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.KafkaException extends RuntimeException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.TopicPartition extends Object implements Serializable

serialVersionUID:

-613627415771699627L

Serialized Fields

hash

int hash

partition

int partition

topic

String topic

Class org.apache.kafka.common.TopicPartitionReplica extends Object implements Serializable

Serialized Fields

hash

int hash

brokerId

int brokerId

partition

int partition

topic

String topic

Package org.apache.kafka.common.config

Class org.apache.kafka.common.config.ConfigException extends KafkaException implements Serializable

serialVersionUID:

1L

Package org.apache.kafka.common.errors

Class org.apache.kafka.common.errors.ApiException extends KafkaException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.AuthenticationException extends ApiException implements Serializable

serialVersionUID:

1L

Serialized Fields

errorInfo

org.apache.kafka.server.audit.AuthenticationErrorInfo errorInfo

Class org.apache.kafka.common.errors.AuthenticationTimeoutException extends SaslAuthenticationException implements Serializable

Class org.apache.kafka.common.errors.AuthorizationException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.AuthorizerNotReadyException extends RetriableException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.BalanceCannotBeImprovedException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.BalancerBrokerExcludedForReplicaPlacementException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.BalancerJbodEnabledMisconfigurationException extends BalancerMisconfigurationException implements Serializable

Class org.apache.kafka.common.errors.BalancerLoadError extends ApiException implements Serializable

Class org.apache.kafka.common.errors.BalancerMisconfigurationException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.BalancerOfflineException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.BalancerOperationFailedException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.BrokerAdditionInProgressException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.BrokerFailureFixInProgressException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.BrokerIdNotRegisteredException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.BrokerNotAvailableException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.BrokerRegistrationDoesNotContainActiveSecretException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.BrokerRemovalCanceledException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.BrokerRemovalInProgressException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.BrokerRemovedException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.BrokerReplicaExclusionNotFoundException extends InvalidBrokerReplicaExclusionException implements Serializable

Class org.apache.kafka.common.errors.CellNotFoundException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.ClusterAuthorizationException extends AuthorizationException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.ClusterLinkDisabledException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.ClusterLinkExistsException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.ClusterLinkInUseException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.ClusterLinkNotFoundException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.ClusterLinkPausedException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.ConcurrentTransactionsException extends RetriableException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.ControllerMovedException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.ControllerRegistrationDoesNotContainActiveSecretException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.CoordinatorLoadInProgressException extends RetriableException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.CoordinatorNotAvailableException extends RetriableException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.CorruptRecordException extends RetriableException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.DelegationTokenAuthorizationException extends AuthorizationException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.DelegationTokenDisabledException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.DelegationTokenExpiredException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.DelegationTokenNotFoundException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.DelegationTokenOwnerMismatchException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.DemotionLimitReachedException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.DisconnectException extends RetriableException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.DuplicateBrokerRegistrationException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.DuplicateResourceException extends ApiException implements Serializable

serialVersionUID:

1L

Serialized Fields

resource

String resource

Class org.apache.kafka.common.errors.DuplicateSequenceException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.ElectionNotNeededException extends InvalidMetadataException implements Serializable

Class org.apache.kafka.common.errors.EligibleLeadersNotAvailableException extends InvalidMetadataException implements Serializable

Class org.apache.kafka.common.errors.EvenClusterLoadTaskInProgressException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.FeatureUpdateFailedException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.FencedInstanceIdException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.FencedLeaderEpochException extends InvalidMetadataException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.FencedMemberEpochException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.FencedReplicationSessionIdException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.FetchSessionIdNotFoundException extends RetriableException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.FetchSessionTopicIdException extends RetriableException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.GroupAuthorizationException extends AuthorizationException implements Serializable

Serialized Fields

groupId

String groupId

Class org.apache.kafka.common.errors.GroupIdNotFoundException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.GroupMaxSizeReachedException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.GroupNotEmptyException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.GroupSubscribedToTopicException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.IllegalGenerationException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.IllegalSaslStateException extends AuthenticationException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.InconsistentClusterIdException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.InconsistentGroupProtocolException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.InconsistentTopicIdException extends InvalidMetadataException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.InconsistentVoterSetException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.IneligibleReplicaException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.InsufficientDataForCellLoadComputationException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.InsufficientRebalancePlanMetricsException extends RebalancePlanComputationException implements Serializable

Class org.apache.kafka.common.errors.InterruptException extends KafkaException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.InvalidBrokerRemovalException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.InvalidBrokerReplicaExclusionException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.InvalidClusterLinkException extends ApiException implements Serializable

serialVersionUID:

1L

Serialized Fields

clusterLinkError

ClusterLinkError clusterLinkError

linkErrorMessage

String linkErrorMessage

Class org.apache.kafka.common.errors.InvalidCommitOffsetSizeException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.InvalidConfigurationException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.InvalidFetchSessionEpochException extends RetriableException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.InvalidFetchSizeException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.InvalidGroupIdException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.InvalidMetadataException extends RetriableException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.InvalidOffsetException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.InvalidPartitionsException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.InvalidPidMappingException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.InvalidPrincipalTypeException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.InvalidProducerEpochException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.InvalidRegistrationException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.InvalidReplicaAssignmentException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.InvalidReplicationFactorException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.InvalidReplicationOffsetException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.InvalidRequestException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.InvalidRequiredAcksException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.InvalidSessionTimeoutException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.InvalidTimestampException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.InvalidTopicException extends ApiException implements Serializable

serialVersionUID:

1L

Serialized Fields

invalidTopics

Set<E> invalidTopics

Class org.apache.kafka.common.errors.InvalidTxnStateException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.InvalidTxnTimeoutException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.InvalidUpdateVersionException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.KafkaStorageException extends InvalidMetadataException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.LeaderNotAvailableException extends InvalidMetadataException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.ListenerNotFoundException extends InvalidMetadataException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.LogDirNotFoundException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.MemberIdRequiredException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.MismatchedEndpointTypeException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.MultiChecksumTypeException extends RuntimeException implements Serializable

Class org.apache.kafka.common.errors.NetworkException extends InvalidMetadataException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.NewLeaderElectedException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.NoReassignmentInProgressException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.NotControllerException extends RetriableException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.NotCoordinatorException extends RetriableException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.NotEnoughReplicasAfterAppendException extends RetriableException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.NotEnoughReplicasException extends RetriableException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.NotLeaderForPartitionException extends InvalidMetadataException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.NotLeaderOrFollowerException extends NotLeaderForPartitionException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.OffsetMetadataTooLarge extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.OffsetMovedToTieredStorageException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.OffsetNotAvailableException extends RetriableException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.OffsetOutOfRangeException extends InvalidOffsetException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.OffsetTieredException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.OperationNotAttemptedException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.OtherChecksumTypeException extends RuntimeException implements Serializable

Class org.apache.kafka.common.errors.OutOfOrderSequenceException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.PolicyViolationException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.PositionOutOfRangeException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.PreferredLeaderNotAvailableException extends InvalidMetadataException implements Serializable

Class org.apache.kafka.common.errors.PrincipalDeserializationException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.ProducerFencedException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.PushReplicationStartedException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.QuotaEntityNotFoundException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.ReassignmentInProgressException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.RebalanceInProgressDuringPlanComputationException extends RebalancePlanComputationException implements Serializable

Class org.apache.kafka.common.errors.RebalanceInProgressException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.RebalancePlanComputationException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.RecordBatchTooLargeException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.RecordDeserializationException extends SerializationException implements Serializable

serialVersionUID:

1L

Serialized Fields

partition

TopicPartition partition

offset

long offset

Class org.apache.kafka.common.errors.RecordTooLargeException extends ApiException implements Serializable

serialVersionUID:

1L

Serialized Fields

recordTooLargePartitions

Map<K,V> recordTooLargePartitions

Class org.apache.kafka.common.errors.ReplicaNotAvailableException extends InvalidMetadataException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.ResourceNotFoundException extends ApiException implements Serializable

serialVersionUID:

1L

Serialized Fields

resource

String resource

Class org.apache.kafka.common.errors.RetriableException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.SaslAuthenticationException extends AuthenticationException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.SecretsLogFailedException extends KafkaException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.SecurityDisabledException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.SerializationException extends KafkaException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.SnapshotNotFoundException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.SslAuthenticationException extends AuthenticationException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.StaleBrokerEpochException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.StaleMemberEpochException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.TelemetryTooLargeException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.TenantNotFoundException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.ThrottlingQuotaExceededException extends RetriableException implements Serializable

Serialized Fields

throttleTimeMs

int throttleTimeMs

Class org.apache.kafka.common.errors.TimeoutException extends RetriableException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.TopicAuthorizationException extends AuthorizationException implements Serializable

Serialized Fields

unauthorizedTopics

Set<E> unauthorizedTopics

Class org.apache.kafka.common.errors.TopicDeletionDisabledException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.TopicExistsException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.TransactionAbortedException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.TransactionalIdAuthorizationException extends AuthorizationException implements Serializable

Class org.apache.kafka.common.errors.TransactionalIdNotFoundException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.TransactionCoordinatorFencedException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.UnacceptableCredentialException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.UnknownControllerIdException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.UnknownLeaderEpochException extends RetriableException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.UnknownMemberIdException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.UnknownProducerIdException extends OutOfOrderSequenceException implements Serializable

Class org.apache.kafka.common.errors.UnknownServerException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.UnknownSubscriptionIdException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.UnknownTopicIdException extends InvalidMetadataException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.UnknownTopicOrPartitionException extends InvalidMetadataException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.UnreleasedInstanceIdException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.UnrepresentableBrokerIdException extends ApiException implements Serializable

Serialized Fields

brokerId

int brokerId

Class org.apache.kafka.common.errors.UnstableOffsetCommitException extends RetriableException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.UnsupportedAssignorException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.UnsupportedByAuthenticationException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.UnsupportedCompressionTypeException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.UnsupportedEndpointTypeException extends ApiException implements Serializable

Class org.apache.kafka.common.errors.UnsupportedForMessageFormatException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.UnsupportedSaslMechanismException extends AuthenticationException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.UnsupportedVersionException extends ApiException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.WakeupException extends KafkaException implements Serializable

serialVersionUID:

1L

Package org.apache.kafka.common.metrics

Class org.apache.kafka.common.metrics.QuotaViolationException extends KafkaException implements Serializable

serialVersionUID:

1L

Serialized Fields

metric

KafkaMetric metric

value

double value

bound

double bound