Serialized Form
Package org.apache.kafka.clients.consumer
Exception Class org.apache.kafka.clients.consumer.CommitFailedException
class CommitFailedException extends KafkaException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.clients.consumer.InvalidOffsetException
class InvalidOffsetException extends KafkaException implements SerializableException Class org.apache.kafka.clients.consumer.LogTruncationException
class LogTruncationException extends OffsetOutOfRangeException implements SerializableSerialized Fields
divergentOffsets
Map<TopicPartition, OffsetAndMetadata> divergentOffsets
Exception Class org.apache.kafka.clients.consumer.NoOffsetForPartitionException
class NoOffsetForPartitionException extends InvalidOffsetException implements Serializable- serialVersionUID:
- 1L
Serialized Fields
partitions
Set<TopicPartition> partitions
Class org.apache.kafka.clients.consumer.OffsetAndMetadata
class OffsetAndMetadata extends Object implements Serializable- serialVersionUID:
- 2019555404968089681L
Exception Class org.apache.kafka.clients.consumer.OffsetOutOfRangeException
class OffsetOutOfRangeException extends InvalidOffsetException implements Serializable- serialVersionUID:
- 1L
Serialized Fields
offsetOutOfRangePartitions
Map<TopicPartition, Long> offsetOutOfRangePartitions
Exception Class org.apache.kafka.clients.consumer.RetriableCommitFailedException
class RetriableCommitFailedException extends RetriableException implements Serializable- serialVersionUID:
- 1L
Package org.apache.kafka.clients.producer
Exception Class org.apache.kafka.clients.producer.BufferExhaustedException
class BufferExhaustedException extends TimeoutException implements Serializable- serialVersionUID:
- 1L
Package org.apache.kafka.common
Exception Class org.apache.kafka.common.InvalidRecordException
class InvalidRecordException extends InvalidConfigurationException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.KafkaException
class KafkaException extends RuntimeException implements Serializable- serialVersionUID:
- 1L
Class org.apache.kafka.common.TopicPartition
class TopicPartition extends Object implements Serializable- serialVersionUID:
- -613627415771699627L
Serialized Fields
hash
int hash
partition
int partition
topic
String topic
Class org.apache.kafka.common.TopicPartitionReplica
class TopicPartitionReplica extends Object implements SerializableSerialized Fields
brokerId
int brokerId
hash
int hash
partition
int partition
topic
String topic
Package org.apache.kafka.common.config
Exception Class org.apache.kafka.common.config.ConfigException
class ConfigException extends KafkaException implements Serializable- serialVersionUID:
- 1L
Package org.apache.kafka.common.errors
Exception Class org.apache.kafka.common.errors.ApiException
class ApiException extends KafkaException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.ApplicationRecoverableException
class ApplicationRecoverableException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.AuthenticationException
class AuthenticationException extends InvalidConfigurationException implements Serializable- serialVersionUID:
- 1L
Serialized Fields
errorInfo
org.apache.kafka.server.audit.AuthenticationErrorInfo errorInfo
Exception Class org.apache.kafka.common.errors.AuthenticationTimeoutException
class AuthenticationTimeoutException extends SaslAuthenticationException implements SerializableException Class org.apache.kafka.common.errors.AuthorizationException
class AuthorizationException extends InvalidConfigurationException implements SerializableException Class org.apache.kafka.common.errors.AuthorizerNotReadyException
class AuthorizerNotReadyException extends RetriableException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.BalanceCannotBeImprovedException
class BalanceCannotBeImprovedException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.BalancerBrokerExcludedForReplicaPlacementException
class BalancerBrokerExcludedForReplicaPlacementException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.BalancerJbodEnabledMisconfigurationException
class BalancerJbodEnabledMisconfigurationException extends BalancerMisconfigurationException implements SerializableException Class org.apache.kafka.common.errors.BalancerLoadError
class BalancerLoadError extends ApiException implements SerializableException Class org.apache.kafka.common.errors.BalancerMisconfigurationException
class BalancerMisconfigurationException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.BalancerOfflineException
class BalancerOfflineException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.BalancerOperationFailedException
class BalancerOperationFailedException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.BrokerAdditionInProgressException
class BrokerAdditionInProgressException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.BrokerFailureFixInProgressException
class BrokerFailureFixInProgressException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.BrokerIdNotRegisteredException
class BrokerIdNotRegisteredException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.BrokerNotAvailableException
class BrokerNotAvailableException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.BrokerRegistrationDoesNotContainEncryptorSecretException
class BrokerRegistrationDoesNotContainEncryptorSecretException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.BrokerRemovalCanceledException
class BrokerRemovalCanceledException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.BrokerRemovalInProgressException
class BrokerRemovalInProgressException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.BrokerRemovedException
class BrokerRemovedException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.BrokerReplicaExclusionNotFoundException
class BrokerReplicaExclusionNotFoundException extends InvalidBrokerReplicaExclusionException implements SerializableException Class org.apache.kafka.common.errors.CellNotFoundException
class CellNotFoundException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.ClusterAuthorizationException
class ClusterAuthorizationException extends AuthorizationException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.ClusterLinkDisabledException
class ClusterLinkDisabledException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.ClusterLinkExistsException
class ClusterLinkExistsException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.ClusterLinkInUseException
class ClusterLinkInUseException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.ClusterLinkNotFoundException
class ClusterLinkNotFoundException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.ClusterLinkPausedException
class ClusterLinkPausedException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.ConcurrentTransactionsException
class ConcurrentTransactionsException extends RetriableException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.ControllerMovedException
class ControllerMovedException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.ControllerRegistrationDoesNotContainActiveSecretException
class ControllerRegistrationDoesNotContainActiveSecretException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.CoordinatorLoadInProgressException
class CoordinatorLoadInProgressException extends RetriableException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.CoordinatorNotAvailableException
class CoordinatorNotAvailableException extends RefreshRetriableException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.CorruptRecordException
class CorruptRecordException extends RetriableException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.DelegationTokenAuthorizationException
class DelegationTokenAuthorizationException extends AuthorizationException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.DelegationTokenDisabledException
class DelegationTokenDisabledException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.DelegationTokenExpiredException
class DelegationTokenExpiredException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.DelegationTokenNotFoundException
class DelegationTokenNotFoundException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.DelegationTokenOwnerMismatchException
class DelegationTokenOwnerMismatchException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.DemotionLimitReachedException
class DemotionLimitReachedException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.DisconnectException
class DisconnectException extends RetriableException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.DuplicateBrokerRegistrationException
class DuplicateBrokerRegistrationException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.DuplicateResourceException
class DuplicateResourceException extends ApiException implements Serializable- serialVersionUID:
- 1L
Serialized Fields
resource
String resource
Exception Class org.apache.kafka.common.errors.DuplicateSequenceException
class DuplicateSequenceException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.DuplicateVoterException
class DuplicateVoterException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.ElectionNotNeededException
class ElectionNotNeededException extends InvalidMetadataException implements SerializableException Class org.apache.kafka.common.errors.EligibleLeadersNotAvailableException
class EligibleLeadersNotAvailableException extends InvalidMetadataException implements SerializableException Class org.apache.kafka.common.errors.EvenClusterLoadTaskInProgressException
class EvenClusterLoadTaskInProgressException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.FeatureUpdateFailedException
class FeatureUpdateFailedException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.FencedInstanceIdException
class FencedInstanceIdException extends ApplicationRecoverableException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.FencedLeaderEpochException
class FencedLeaderEpochException extends InvalidMetadataException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.FencedMemberEpochException
class FencedMemberEpochException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.FencedReplicationSessionIdException
class FencedReplicationSessionIdException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.FencedStateEpochException
class FencedStateEpochException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.FetchSessionIdNotFoundException
class FetchSessionIdNotFoundException extends RetriableException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.FetchSessionTopicIdException
class FetchSessionTopicIdException extends RetriableException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.GroupAuthorizationException
class GroupAuthorizationException extends AuthorizationException implements SerializableSerialized Fields
groupId
String groupId
Exception Class org.apache.kafka.common.errors.GroupIdNotFoundException
class GroupIdNotFoundException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.GroupMaxSizeReachedException
class GroupMaxSizeReachedException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.GroupNotEmptyException
class GroupNotEmptyException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.GroupSubscribedToTopicException
class GroupSubscribedToTopicException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.IllegalGenerationException
class IllegalGenerationException extends ApplicationRecoverableException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.IllegalSaslStateException
class IllegalSaslStateException extends AuthenticationException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InconsistentClusterIdException
class InconsistentClusterIdException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.InconsistentGroupProtocolException
class InconsistentGroupProtocolException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InconsistentTopicIdException
class InconsistentTopicIdException extends InvalidMetadataException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InconsistentVoterSetException
class InconsistentVoterSetException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.IneligibleReplicaException
class IneligibleReplicaException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.InsufficientDataForCellLoadComputationException
class InsufficientDataForCellLoadComputationException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.InsufficientRebalancePlanMetricsException
class InsufficientRebalancePlanMetricsException extends RebalancePlanComputationException implements SerializableException Class org.apache.kafka.common.errors.InterruptException
class InterruptException extends KafkaException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InvalidBrokerRemovalException
class InvalidBrokerRemovalException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.InvalidBrokerReplicaExclusionException
class InvalidBrokerReplicaExclusionException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.InvalidClusterLinkException
class InvalidClusterLinkException extends ApiException implements Serializable- serialVersionUID:
- 1L
Serialized Fields
clusterLinkError
ClusterLinkError clusterLinkError
linkErrorMessage
String linkErrorMessage
Exception Class org.apache.kafka.common.errors.InvalidCommitOffsetSizeException
class InvalidCommitOffsetSizeException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InvalidConfigurationException
class InvalidConfigurationException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InvalidFetchSessionEpochException
class InvalidFetchSessionEpochException extends RetriableException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InvalidFetchSizeException
class InvalidFetchSizeException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InvalidGroupIdException
class InvalidGroupIdException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InvalidMetadataException
class InvalidMetadataException extends RefreshRetriableException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InvalidOffsetException
class InvalidOffsetException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InvalidPartitionsException
class InvalidPartitionsException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InvalidPidMappingException
class InvalidPidMappingException extends ApplicationRecoverableException implements SerializableException Class org.apache.kafka.common.errors.InvalidPrincipalTypeException
class InvalidPrincipalTypeException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InvalidProducerEpochException
class InvalidProducerEpochException extends ApplicationRecoverableException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InvalidRecordStateException
class InvalidRecordStateException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InvalidRegistrationException
class InvalidRegistrationException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InvalidRegularExpression
class InvalidRegularExpression extends ApiException implements SerializableException Class org.apache.kafka.common.errors.InvalidReplicaAssignmentException
class InvalidReplicaAssignmentException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InvalidReplicationFactorException
class InvalidReplicationFactorException extends InvalidConfigurationException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InvalidReplicationOffsetException
class InvalidReplicationOffsetException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InvalidRequestException
class InvalidRequestException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InvalidRequiredAcksException
class InvalidRequiredAcksException extends InvalidConfigurationException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InvalidSessionTimeoutException
class InvalidSessionTimeoutException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InvalidTimestampException
class InvalidTimestampException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InvalidTopicException
class InvalidTopicException extends InvalidConfigurationException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InvalidTxnStateException
class InvalidTxnStateException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.InvalidTxnTimeoutException
class InvalidTxnTimeoutException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.InvalidUpdateVersionException
class InvalidUpdateVersionException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.InvalidVoterKeyException
class InvalidVoterKeyException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.KafkaStorageException
class KafkaStorageException extends InvalidMetadataException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.KafkaStorageMetadataCorruptionException
class KafkaStorageMetadataCorruptionException extends InvalidMetadataException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.LeaderNotAvailableException
class LeaderNotAvailableException extends InvalidMetadataException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.ListenerNotFoundException
class ListenerNotFoundException extends InvalidMetadataException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.LogDirNotFoundException
class LogDirNotFoundException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.MemberIdRequiredException
class MemberIdRequiredException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.MetadataNotAvailableException
class MetadataNotAvailableException extends RetriableException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.MismatchedEndpointTypeException
class MismatchedEndpointTypeException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.MultiChecksumTypeException
class MultiChecksumTypeException extends RuntimeException implements SerializableException Class org.apache.kafka.common.errors.NetworkException
class NetworkException extends InvalidMetadataException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.NewLeaderElectedException
class NewLeaderElectedException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.NoReassignmentInProgressException
class NoReassignmentInProgressException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.NotControllerException
class NotControllerException extends RetriableException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.NotCoordinatorException
class NotCoordinatorException extends RefreshRetriableException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.NotEnoughReplicasAfterAppendException
class NotEnoughReplicasAfterAppendException extends RetriableException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.NotEnoughReplicasException
class NotEnoughReplicasException extends RetriableException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.NotLeaderOrFollowerException
class NotLeaderOrFollowerException extends InvalidMetadataException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.OffsetMetadataTooLarge
class OffsetMetadataTooLarge extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.OffsetMovedToTieredStorageException
class OffsetMovedToTieredStorageException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.OffsetNotAvailableException
class OffsetNotAvailableException extends RetriableException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.OffsetOutOfRangeException
class OffsetOutOfRangeException extends InvalidOffsetException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.OffsetTieredException
class OffsetTieredException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.OperationNotAttemptedException
class OperationNotAttemptedException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.OtherChecksumTypeException
class OtherChecksumTypeException extends RuntimeException implements SerializableException Class org.apache.kafka.common.errors.OutOfOrderSequenceException
class OutOfOrderSequenceException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.PolicyViolationException
class PolicyViolationException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.PositionOutOfRangeException
class PositionOutOfRangeException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.PreferredLeaderNotAvailableException
class PreferredLeaderNotAvailableException extends InvalidMetadataException implements SerializableException Class org.apache.kafka.common.errors.PrincipalDeserializationException
class PrincipalDeserializationException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.ProducerFencedException
class ProducerFencedException extends ApplicationRecoverableException implements SerializableException Class org.apache.kafka.common.errors.PushReplicationStartedException
class PushReplicationStartedException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.QuotaEntityNotFoundException
class QuotaEntityNotFoundException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.ReassignmentInProgressException
class ReassignmentInProgressException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.RebalanceInProgressDuringPlanComputationException
class RebalanceInProgressDuringPlanComputationException extends RebalancePlanComputationException implements SerializableException Class org.apache.kafka.common.errors.RebalanceInProgressException
class RebalanceInProgressException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.RebalancePlanComputationException
class RebalancePlanComputationException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.RebootstrapRequiredException
class RebootstrapRequiredException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.RecordBatchTooLargeException
class RecordBatchTooLargeException extends InvalidConfigurationException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.RecordDeserializationException
class RecordDeserializationException extends SerializationException implements Serializable- serialVersionUID:
- 2L
Serialized Fields
headers
Headers headers
keyBuffer
ByteBuffer keyBuffer
offset
long offset
origin
RecordDeserializationException.DeserializationExceptionOrigin origin
partition
TopicPartition partition
timestamp
long timestamp
timestampType
org.apache.kafka.common.record.TimestampType timestampType
valueBuffer
ByteBuffer valueBuffer
Exception Class org.apache.kafka.common.errors.RecordTooLargeException
class RecordTooLargeException extends ApiException implements Serializable- serialVersionUID:
- 1L
Serialized Fields
recordTooLargePartitions
Map<TopicPartition, Long> recordTooLargePartitions
Exception Class org.apache.kafka.common.errors.RefreshRetriableException
class RefreshRetriableException extends RetriableException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.ReplicaNotAvailableException
class ReplicaNotAvailableException extends InvalidMetadataException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.ResourceNotFoundException
class ResourceNotFoundException extends ApiException implements Serializable- serialVersionUID:
- 1L
Serialized Fields
resource
String resource
Exception Class org.apache.kafka.common.errors.RetriableException
class RetriableException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.SaslAuthenticationException
class SaslAuthenticationException extends AuthenticationException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.SecretsLogFailedException
class SecretsLogFailedException extends KafkaException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.SecurityDisabledException
class SecurityDisabledException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.SerializationException
class SerializationException extends KafkaException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.SnapshotNotFoundException
class SnapshotNotFoundException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.SslAuthenticationException
class SslAuthenticationException extends AuthenticationException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.StaleBrokerEpochException
class StaleBrokerEpochException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.StaleMemberEpochException
class StaleMemberEpochException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.StreamsInvalidTopologyEpochException
class StreamsInvalidTopologyEpochException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.StreamsInvalidTopologyException
class StreamsInvalidTopologyException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.StreamsTopologyFencedException
class StreamsTopologyFencedException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.TelemetryTooLargeException
class TelemetryTooLargeException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.TenantNotFoundException
class TenantNotFoundException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.ThrottlingQuotaExceededException
class ThrottlingQuotaExceededException extends RetriableException implements SerializableSerialized Fields
throttleTimeMs
int throttleTimeMs
Exception Class org.apache.kafka.common.errors.TimeoutException
class TimeoutException extends RetriableException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.TopicAuthorizationException
class TopicAuthorizationException extends AuthorizationException implements SerializableException Class org.apache.kafka.common.errors.TopicDeletionDisabledException
class TopicDeletionDisabledException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.TopicExistsException
class TopicExistsException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.TransactionAbortableException
class TransactionAbortableException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.TransactionAbortedException
class TransactionAbortedException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.TransactionalIdAuthorizationException
class TransactionalIdAuthorizationException extends AuthorizationException implements SerializableException Class org.apache.kafka.common.errors.TransactionalIdNotFoundException
class TransactionalIdNotFoundException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.TransactionCoordinatorFencedException
class TransactionCoordinatorFencedException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.UnacceptableCredentialException
class UnacceptableCredentialException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.UnknownControllerIdException
class UnknownControllerIdException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.UnknownLeaderEpochException
class UnknownLeaderEpochException extends RetriableException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.UnknownMemberIdException
class UnknownMemberIdException extends ApplicationRecoverableException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.UnknownProducerIdException
class UnknownProducerIdException extends OutOfOrderSequenceException implements SerializableException Class org.apache.kafka.common.errors.UnknownServerException
class UnknownServerException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.UnknownSubscriptionIdException
class UnknownSubscriptionIdException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.UnknownTopicIdException
class UnknownTopicIdException extends InvalidMetadataException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.UnknownTopicOrPartitionException
class UnknownTopicOrPartitionException extends InvalidMetadataException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.UnreleasedInstanceIdException
class UnreleasedInstanceIdException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.UnrepresentableBrokerIdException
class UnrepresentableBrokerIdException extends ApiException implements SerializableSerialized Fields
brokerId
int brokerId
Exception Class org.apache.kafka.common.errors.UnstableOffsetCommitException
class UnstableOffsetCommitException extends RetriableException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.UnsupportedAssignorException
class UnsupportedAssignorException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.UnsupportedByAuthenticationException
class UnsupportedByAuthenticationException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.UnsupportedCompressionTypeException
class UnsupportedCompressionTypeException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.UnsupportedEndpointTypeException
class UnsupportedEndpointTypeException extends ApiException implements SerializableException Class org.apache.kafka.common.errors.UnsupportedForMessageFormatException
class UnsupportedForMessageFormatException extends InvalidConfigurationException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.UnsupportedSaslMechanismException
class UnsupportedSaslMechanismException extends AuthenticationException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.UnsupportedVersionException
class UnsupportedVersionException extends InvalidConfigurationException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.VoterNotFoundException
class VoterNotFoundException extends ApiException implements Serializable- serialVersionUID:
- 1L
Exception Class org.apache.kafka.common.errors.WakeupException
class WakeupException extends KafkaException implements Serializable- serialVersionUID:
- 1L
Package org.apache.kafka.common.metrics
Exception Class org.apache.kafka.common.metrics.QuotaViolationException
class QuotaViolationException extends KafkaException implements Serializable- serialVersionUID:
- 1L
Serialized Fields
bound
double bound
metric
KafkaMetric metric
value
double value
Package org.apache.kafka.common.security.oauthbearer
Exception Class org.apache.kafka.common.security.oauthbearer.JwtRetrieverException
class JwtRetrieverException extends KafkaException implements SerializableException Class org.apache.kafka.common.security.oauthbearer.JwtValidatorException
class JwtValidatorException extends KafkaException implements Serializable