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

partition

TopicPartition partition

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

Serialized Fields

offset

long offset

metadata

String metadata

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 KafkaException implements Serializable

serialVersionUID:

1L

Package org.apache.kafka.common

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

serialVersionUID:

1L

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

Serialized Fields

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

serialVersionUID:

1L

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

serialVersionUID:

1L

Class org.apache.kafka.common.errors.DisconnectException 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.GroupCoordinatorNotAvailableException extends RetriableException implements Serializable

serialVersionUID:

1L

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

serialVersionUID:

1L

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.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.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.LeaderNotAvailableException extends InvalidMetadataException 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.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.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<K,V> 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.SerializationException extends KafkaException 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

Set<E> unauthorizedTopics

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

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

serialVersionUID:

1L

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

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

serialVersionUID:

1L