Serialized Form
-
Package org.apache.kafka.clients.consumer
-
Exception org.apache.kafka.clients.consumer.CommitFailedException
class CommitFailedException extends KafkaException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.clients.consumer.InvalidOffsetException
class InvalidOffsetException extends KafkaException implements Serializable -
Exception org.apache.kafka.clients.consumer.LogTruncationException
class LogTruncationException extends OffsetOutOfRangeException implements Serializable-
Serialized Fields
-
divergentOffsets
Map<TopicPartition,
OffsetAndMetadata> divergentOffsets
-
-
-
Exception 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 org.apache.kafka.clients.consumer.OffsetOutOfRangeException
class OffsetOutOfRangeException extends InvalidOffsetException implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
offsetOutOfRangePartitions
Map<TopicPartition,
Long> offsetOutOfRangePartitions
-
-
Exception org.apache.kafka.clients.consumer.RetriableCommitFailedException
class RetriableCommitFailedException extends RetriableException implements Serializable- serialVersionUID:
- 1L
-
-
Package org.apache.kafka.clients.producer
-
Exception org.apache.kafka.clients.producer.BufferExhaustedException
class BufferExhaustedException extends TimeoutException implements Serializable- serialVersionUID:
- 1L
-
-
Package org.apache.kafka.common
-
Exception org.apache.kafka.common.InvalidRecordException
class InvalidRecordException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception 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 Serializable-
Serialized Fields
-
brokerId
int brokerId
-
hash
int hash
-
partition
int partition
-
topic
String topic
-
-
-
-
Package org.apache.kafka.common.config
-
Exception org.apache.kafka.common.config.ConfigException
class ConfigException extends KafkaException implements Serializable- serialVersionUID:
- 1L
-
-
Package org.apache.kafka.common.errors
-
Exception org.apache.kafka.common.errors.ApiException
class ApiException extends KafkaException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.AuthenticationException
class AuthenticationException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.AuthorizationException
class AuthorizationException extends ApiException implements Serializable -
Exception org.apache.kafka.common.errors.AuthorizerNotReadyException
class AuthorizerNotReadyException extends RetriableException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.BrokerIdNotRegisteredException
class BrokerIdNotRegisteredException extends ApiException implements Serializable -
Exception org.apache.kafka.common.errors.BrokerNotAvailableException
class BrokerNotAvailableException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.ClusterAuthorizationException
class ClusterAuthorizationException extends AuthorizationException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.ConcurrentTransactionsException
class ConcurrentTransactionsException extends RetriableException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.ControllerMovedException
class ControllerMovedException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.CoordinatorLoadInProgressException
class CoordinatorLoadInProgressException extends RetriableException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.CoordinatorNotAvailableException
class CoordinatorNotAvailableException extends RetriableException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.CorruptRecordException
class CorruptRecordException extends RetriableException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.DelegationTokenAuthorizationException
class DelegationTokenAuthorizationException extends AuthorizationException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.DelegationTokenDisabledException
class DelegationTokenDisabledException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.DelegationTokenExpiredException
class DelegationTokenExpiredException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.DelegationTokenNotFoundException
class DelegationTokenNotFoundException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.DelegationTokenOwnerMismatchException
class DelegationTokenOwnerMismatchException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.DisconnectException
class DisconnectException extends RetriableException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.DuplicateBrokerRegistrationException
class DuplicateBrokerRegistrationException extends ApiException implements Serializable -
Exception org.apache.kafka.common.errors.DuplicateResourceException
class DuplicateResourceException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
resource
String resource
-
-
Exception org.apache.kafka.common.errors.DuplicateSequenceException
class DuplicateSequenceException extends ApiException implements Serializable -
Exception org.apache.kafka.common.errors.ElectionNotNeededException
class ElectionNotNeededException extends InvalidMetadataException implements Serializable -
Exception org.apache.kafka.common.errors.EligibleLeadersNotAvailableException
class EligibleLeadersNotAvailableException extends InvalidMetadataException implements Serializable -
Exception org.apache.kafka.common.errors.FeatureUpdateFailedException
class FeatureUpdateFailedException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.FencedInstanceIdException
class FencedInstanceIdException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.FencedLeaderEpochException
class FencedLeaderEpochException extends InvalidMetadataException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.FetchSessionIdNotFoundException
class FetchSessionIdNotFoundException extends RetriableException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.FetchSessionTopicIdException
class FetchSessionTopicIdException extends RetriableException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.GroupAuthorizationException
class GroupAuthorizationException extends AuthorizationException implements Serializable-
Serialized Fields
-
groupId
String groupId
-
-
-
Exception org.apache.kafka.common.errors.GroupIdNotFoundException
class GroupIdNotFoundException extends ApiException implements Serializable -
Exception org.apache.kafka.common.errors.GroupMaxSizeReachedException
class GroupMaxSizeReachedException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.GroupNotEmptyException
class GroupNotEmptyException extends ApiException implements Serializable -
Exception org.apache.kafka.common.errors.GroupSubscribedToTopicException
class GroupSubscribedToTopicException extends ApiException implements Serializable -
Exception org.apache.kafka.common.errors.IllegalGenerationException
class IllegalGenerationException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.IllegalSaslStateException
class IllegalSaslStateException extends AuthenticationException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.InconsistentClusterIdException
class InconsistentClusterIdException extends ApiException implements Serializable -
Exception org.apache.kafka.common.errors.InconsistentGroupProtocolException
class InconsistentGroupProtocolException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.InconsistentTopicIdException
class InconsistentTopicIdException extends InvalidMetadataException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.InconsistentVoterSetException
class InconsistentVoterSetException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.IneligibleReplicaException
class IneligibleReplicaException extends ApiException implements Serializable -
Exception org.apache.kafka.common.errors.InterruptException
class InterruptException extends KafkaException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.InvalidCommitOffsetSizeException
class InvalidCommitOffsetSizeException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.InvalidConfigurationException
class InvalidConfigurationException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.InvalidFetchSessionEpochException
class InvalidFetchSessionEpochException extends RetriableException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.InvalidFetchSizeException
class InvalidFetchSizeException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.InvalidGroupIdException
class InvalidGroupIdException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.InvalidMetadataException
class InvalidMetadataException extends RetriableException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.InvalidOffsetException
class InvalidOffsetException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.InvalidPartitionsException
class InvalidPartitionsException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.InvalidPidMappingException
class InvalidPidMappingException extends ApiException implements Serializable -
Exception org.apache.kafka.common.errors.InvalidPrincipalTypeException
class InvalidPrincipalTypeException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.InvalidProducerEpochException
class InvalidProducerEpochException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.InvalidReplicaAssignmentException
class InvalidReplicaAssignmentException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.InvalidReplicationFactorException
class InvalidReplicationFactorException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.InvalidRequestException
class InvalidRequestException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.InvalidRequiredAcksException
class InvalidRequiredAcksException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.InvalidSessionTimeoutException
class InvalidSessionTimeoutException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.InvalidTimestampException
class InvalidTimestampException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.InvalidTopicException
class InvalidTopicException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.InvalidTxnStateException
class InvalidTxnStateException extends ApiException implements Serializable -
Exception org.apache.kafka.common.errors.InvalidTxnTimeoutException
class InvalidTxnTimeoutException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.InvalidUpdateVersionException
class InvalidUpdateVersionException extends ApiException implements Serializable -
Exception org.apache.kafka.common.errors.KafkaStorageException
class KafkaStorageException extends InvalidMetadataException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.LeaderNotAvailableException
class LeaderNotAvailableException extends InvalidMetadataException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.ListenerNotFoundException
class ListenerNotFoundException extends InvalidMetadataException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.LogDirNotFoundException
class LogDirNotFoundException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.MemberIdRequiredException
class MemberIdRequiredException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.NetworkException
class NetworkException extends InvalidMetadataException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.NewLeaderElectedException
class NewLeaderElectedException extends ApiException implements Serializable -
Exception org.apache.kafka.common.errors.NoReassignmentInProgressException
class NoReassignmentInProgressException extends ApiException implements Serializable -
Exception org.apache.kafka.common.errors.NotControllerException
class NotControllerException extends RetriableException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.NotCoordinatorException
class NotCoordinatorException extends RetriableException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.NotEnoughReplicasAfterAppendException
class NotEnoughReplicasAfterAppendException extends RetriableException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.NotEnoughReplicasException
class NotEnoughReplicasException extends RetriableException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.NotLeaderForPartitionException
class NotLeaderForPartitionException extends InvalidMetadataException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.NotLeaderOrFollowerException
class NotLeaderOrFollowerException extends NotLeaderForPartitionException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.OffsetMetadataTooLarge
class OffsetMetadataTooLarge extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.OffsetNotAvailableException
class OffsetNotAvailableException extends RetriableException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.OffsetOutOfRangeException
class OffsetOutOfRangeException extends InvalidOffsetException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.OperationNotAttemptedException
class OperationNotAttemptedException extends ApiException implements Serializable -
Exception org.apache.kafka.common.errors.OutOfOrderSequenceException
class OutOfOrderSequenceException extends ApiException implements Serializable -
Exception org.apache.kafka.common.errors.PolicyViolationException
class PolicyViolationException extends ApiException implements Serializable -
Exception org.apache.kafka.common.errors.PositionOutOfRangeException
class PositionOutOfRangeException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.PreferredLeaderNotAvailableException
class PreferredLeaderNotAvailableException extends InvalidMetadataException implements Serializable -
Exception org.apache.kafka.common.errors.PrincipalDeserializationException
class PrincipalDeserializationException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.ProducerFencedException
class ProducerFencedException extends ApiException implements Serializable -
Exception org.apache.kafka.common.errors.ReassignmentInProgressException
class ReassignmentInProgressException extends ApiException implements Serializable -
Exception org.apache.kafka.common.errors.RebalanceInProgressException
class RebalanceInProgressException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.RecordBatchTooLargeException
class RecordBatchTooLargeException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.RecordDeserializationException
class RecordDeserializationException extends SerializationException implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
offset
long offset
-
partition
TopicPartition partition
-
-
Exception org.apache.kafka.common.errors.RecordTooLargeException
class RecordTooLargeException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
recordTooLargePartitions
Map<TopicPartition,
Long> recordTooLargePartitions
-
-
Exception org.apache.kafka.common.errors.ReplicaNotAvailableException
class ReplicaNotAvailableException extends InvalidMetadataException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.ResourceNotFoundException
class ResourceNotFoundException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
resource
String resource
-
-
Exception org.apache.kafka.common.errors.RetriableException
class RetriableException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.SaslAuthenticationException
class SaslAuthenticationException extends AuthenticationException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.SecurityDisabledException
class SecurityDisabledException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.SerializationException
class SerializationException extends KafkaException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.SnapshotNotFoundException
class SnapshotNotFoundException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.SslAuthenticationException
class SslAuthenticationException extends AuthenticationException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.StaleBrokerEpochException
class StaleBrokerEpochException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.ThrottlingQuotaExceededException
class ThrottlingQuotaExceededException extends RetriableException implements Serializable-
Serialized Fields
-
throttleTimeMs
int throttleTimeMs
-
-
-
Exception org.apache.kafka.common.errors.TimeoutException
class TimeoutException extends RetriableException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.TopicAuthorizationException
class TopicAuthorizationException extends AuthorizationException implements Serializable -
Exception org.apache.kafka.common.errors.TopicDeletionDisabledException
class TopicDeletionDisabledException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.TopicExistsException
class TopicExistsException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.TransactionAbortedException
class TransactionAbortedException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.TransactionalIdAuthorizationException
class TransactionalIdAuthorizationException extends AuthorizationException implements Serializable -
Exception org.apache.kafka.common.errors.TransactionalIdNotFoundException
class TransactionalIdNotFoundException extends ApiException implements Serializable -
Exception org.apache.kafka.common.errors.TransactionCoordinatorFencedException
class TransactionCoordinatorFencedException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.UnacceptableCredentialException
class UnacceptableCredentialException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.UnknownLeaderEpochException
class UnknownLeaderEpochException extends RetriableException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.UnknownMemberIdException
class UnknownMemberIdException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.UnknownProducerIdException
class UnknownProducerIdException extends OutOfOrderSequenceException implements Serializable -
Exception org.apache.kafka.common.errors.UnknownServerException
class UnknownServerException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.UnknownTopicIdException
class UnknownTopicIdException extends InvalidMetadataException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.UnknownTopicOrPartitionException
class UnknownTopicOrPartitionException extends InvalidMetadataException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.UnstableOffsetCommitException
class UnstableOffsetCommitException extends RetriableException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.UnsupportedByAuthenticationException
class UnsupportedByAuthenticationException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.UnsupportedCompressionTypeException
class UnsupportedCompressionTypeException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.UnsupportedForMessageFormatException
class UnsupportedForMessageFormatException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.UnsupportedSaslMechanismException
class UnsupportedSaslMechanismException extends AuthenticationException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.UnsupportedVersionException
class UnsupportedVersionException extends ApiException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.common.errors.WakeupException
class WakeupException extends KafkaException implements Serializable- serialVersionUID:
- 1L
-
-
Package org.apache.kafka.common.metrics
-
Exception 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.connect.errors
-
Exception org.apache.kafka.connect.errors.AlreadyExistsException
class AlreadyExistsException extends ConnectException implements Serializable -
Exception org.apache.kafka.connect.errors.ConnectException
class ConnectException extends KafkaException implements Serializable -
Exception org.apache.kafka.connect.errors.DataException
class DataException extends ConnectException implements Serializable -
Exception org.apache.kafka.connect.errors.IllegalWorkerStateException
class IllegalWorkerStateException extends ConnectException implements Serializable -
Exception org.apache.kafka.connect.errors.NotFoundException
class NotFoundException extends ConnectException implements Serializable -
Exception org.apache.kafka.connect.errors.RetriableException
class RetriableException extends ConnectException implements Serializable -
Exception org.apache.kafka.connect.errors.SchemaBuilderException
class SchemaBuilderException extends DataException implements Serializable -
Exception org.apache.kafka.connect.errors.SchemaProjectorException
class SchemaProjectorException extends DataException implements Serializable
-
-
Package org.apache.kafka.server.log.remote.storage
-
Exception org.apache.kafka.server.log.remote.storage.RemoteResourceNotFoundException
class RemoteResourceNotFoundException extends RemoteStorageException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.server.log.remote.storage.RemoteStorageException
class RemoteStorageException extends Exception implements Serializable- serialVersionUID:
- 1L
-
-
Package org.apache.kafka.streams.errors
-
Exception org.apache.kafka.streams.errors.BrokerNotFoundException
class BrokerNotFoundException extends StreamsException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.streams.errors.InvalidStateStoreException
class InvalidStateStoreException extends StreamsException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.streams.errors.InvalidStateStorePartitionException
class InvalidStateStorePartitionException extends InvalidStateStoreException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.streams.errors.LockException
class LockException extends StreamsException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.streams.errors.MissingSourceTopicException
class MissingSourceTopicException extends StreamsException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.streams.errors.ProcessorStateException
class ProcessorStateException extends StreamsException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.streams.errors.StateStoreMigratedException
class StateStoreMigratedException extends InvalidStateStoreException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.streams.errors.StateStoreNotAvailableException
class StateStoreNotAvailableException extends InvalidStateStoreException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.streams.errors.StreamsException
class StreamsException extends KafkaException implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
taskId
TaskId taskId
-
-
Exception org.apache.kafka.streams.errors.StreamsNotStartedException
class StreamsNotStartedException extends InvalidStateStoreException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.streams.errors.StreamsRebalancingException
class StreamsRebalancingException extends InvalidStateStoreException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.streams.errors.StreamsStoppedException
class StreamsStoppedException extends InvalidStateStoreException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.streams.errors.TaskAssignmentException
class TaskAssignmentException extends StreamsException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.streams.errors.TaskCorruptedException
class TaskCorruptedException extends StreamsException implements Serializable -
Exception org.apache.kafka.streams.errors.TaskIdFormatException
class TaskIdFormatException extends StreamsException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.streams.errors.TaskMigratedException
class TaskMigratedException extends StreamsException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.streams.errors.TopologyException
class TopologyException extends StreamsException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.streams.errors.UnknownStateStoreException
class UnknownStateStoreException extends InvalidStateStoreException implements Serializable- serialVersionUID:
- 1L
-
Exception org.apache.kafka.streams.errors.UnknownTopologyException
class UnknownTopologyException extends StreamsException implements Serializable- serialVersionUID:
- 1L
-