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

Serialized Fields

leaderEpoch

Integer leaderEpoch

metadata

String metadata

offset

long offset

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

class FencedMemberEpochException extends ApiException implements Serializable

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

Serialized Fields

invalidTopics

Set<String> invalidTopics

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

class OffsetMovedToTieredStorageException 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

Serialized Fields

unauthorizedTopics

Set<String> unauthorizedTopics

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

class UnreleasedInstanceIdException extends ApiException implements Serializable

Exception org.apache.kafka.common.errors.UnstableOffsetCommitException

class UnstableOffsetCommitException extends RetriableException implements Serializable

serialVersionUID:

1L

Exception org.apache.kafka.common.errors.UnsupportedAssignorException

class UnsupportedAssignorException extends ApiException implements Serializable

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

Serialized Fields

corruptedTasks

Set<TaskId> corruptedTasks

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