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<TopicPartition,OffsetAndMetadata> divergentOffsets

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

serialVersionUID:

1L

Serialized Fields

partitions

Set<TopicPartition> partitions

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

serialVersionUID:

2019555404968089681L

Serialized Fields

leaderEpoch

Integer leaderEpoch

metadata

String metadata

offset

long offset

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

serialVersionUID:

1L

Serialized Fields

offsetOutOfRangePartitions

Map<TopicPartition,Long> 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

brokerId

int brokerId

hash

int hash

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

Class org.apache.kafka.common.errors.AuthorizationException 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.ClusterAuthorizationException extends AuthorizationException implements Serializable

serialVersionUID:

1L

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

serialVersionUID:

1L

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

serialVersionUID:

1L

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.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.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.FetchSessionIdNotFoundException 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.InterruptException extends KafkaException implements Serializable

serialVersionUID:

1L

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.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.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<String> 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.NetworkException extends InvalidMetadataException implements Serializable

serialVersionUID:

1L

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.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.OperationNotAttemptedException extends ApiException 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.ReassignmentInProgressException extends ApiException implements Serializable

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

serialVersionUID:

1L

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

serialVersionUID:

1L

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

serialVersionUID:

1L

Serialized Fields

recordTooLargePartitions

Map<TopicPartition,Long> 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.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.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<String> 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.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.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.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.UnstableOffsetCommitException extends RetriableException implements Serializable

serialVersionUID:

1L

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.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

bound

double bound

metric

KafkaMetric metric

value

double value

Package org.apache.kafka.connect.errors

Class org.apache.kafka.connect.errors.AlreadyExistsException extends ConnectException implements Serializable

Class org.apache.kafka.connect.errors.ConnectException extends KafkaException implements Serializable

Class org.apache.kafka.connect.errors.DataException extends ConnectException implements Serializable

Class org.apache.kafka.connect.errors.IllegalWorkerStateException extends ConnectException implements Serializable

Class org.apache.kafka.connect.errors.NotFoundException extends ConnectException implements Serializable

Class org.apache.kafka.connect.errors.RetriableException extends ConnectException implements Serializable

Class org.apache.kafka.connect.errors.SchemaBuilderException extends DataException implements Serializable

Class org.apache.kafka.connect.errors.SchemaProjectorException extends DataException implements Serializable

Package org.apache.kafka.streams.errors

Class org.apache.kafka.streams.errors.BrokerNotFoundException extends StreamsException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.streams.errors.InvalidStateStoreException extends StreamsException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.streams.errors.InvalidStateStorePartitionException extends InvalidStateStoreException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.streams.errors.LockException extends StreamsException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.streams.errors.MissingSourceTopicException extends StreamsException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.streams.errors.ProcessorStateException extends StreamsException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.streams.errors.StateStoreMigratedException extends InvalidStateStoreException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.streams.errors.StateStoreNotAvailableException extends InvalidStateStoreException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.streams.errors.StreamsException extends KafkaException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.streams.errors.StreamsNotStartedException extends InvalidStateStoreException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.streams.errors.StreamsRebalancingException extends InvalidStateStoreException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.streams.errors.TaskAssignmentException extends StreamsException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.streams.errors.TaskCorruptedException extends StreamsException implements Serializable

Serialized Fields

corruptedTasks

Set<TaskId> corruptedTasks

Class org.apache.kafka.streams.errors.TaskIdFormatException extends StreamsException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.streams.errors.TaskMigratedException extends StreamsException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.streams.errors.TopologyException extends StreamsException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.streams.errors.UnknownStateStoreException extends InvalidStateStoreException implements Serializable

serialVersionUID:

1L