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.NoOffsetForPartitionException extends InvalidOffsetException implements Serializable

serialVersionUID:

1L

Serialized Fields

partitions

java.util.Set<E extends java.lang.Object> partitions

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

Serialized Fields

metadata

java.lang.String metadata

offset

long offset

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

serialVersionUID:

1L

Serialized Fields

offsetOutOfRangePartitions

java.util.Map<K extends java.lang.Object,V extends java.lang.Object> 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 KafkaException implements Serializable

serialVersionUID:

1L

Package org.apache.kafka.common

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

serialVersionUID:

1L

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

Serialized Fields

hash

int hash

partition

int partition

topic

java.lang.String topic

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

Serialized Fields

brokerId

int brokerId

hash

int hash

partition

int partition

topic

java.lang.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.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.DuplicateSequenceException extends ApiException implements Serializable

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

java.lang.String groupId

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

serialVersionUID:

1L

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

Serialized Fields

groupId

java.lang.String groupId

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

serialVersionUID:

1L

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

Serialized Fields

groupId

java.lang.String groupId

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

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.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.LogDirNotFoundException 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.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.NotCoordinatorForGroupException 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.OffsetMetadataTooLarge extends ApiException 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.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

java.util.Map<K extends java.lang.Object,V extends java.lang.Object> recordTooLargePartitions

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

serialVersionUID:

1L

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.SslAuthenticationException extends AuthenticationException implements Serializable

serialVersionUID:

1L

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

java.util.Set<E extends java.lang.Object> unauthorizedTopics

Class org.apache.kafka.common.errors.TopicExistsException 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.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.UnknownTopicOrPartitionException extends InvalidMetadataException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.common.errors.UnsupportedByAuthenticationException 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.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.LockException 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.StreamsException extends KafkaException implements Serializable

serialVersionUID:

1L

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

serialVersionUID:

1L

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.TopologyBuilderException extends StreamsException implements Serializable

serialVersionUID:

1L

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

serialVersionUID:

1L