Serialized Form

Package org.springframework.kafka

Exception org.springframework.kafka.KafkaException

class KafkaException extends NestedRuntimeException implements Serializable

Serialized Fields

logLevel

KafkaException.Level logLevel

Package org.springframework.kafka.core

Exception org.springframework.kafka.core.KafkaProducerException

class KafkaProducerException extends KafkaException implements Serializable

Serialized Fields

producerRecord

org.apache.kafka.clients.producer.ProducerRecord<?,?> producerRecord

Package org.springframework.kafka.event

Class org.springframework.kafka.event.ConsumerFailedToStartEvent

class ConsumerFailedToStartEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Class org.springframework.kafka.event.ConsumerPartitionPausedEvent

class ConsumerPartitionPausedEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

partition

org.apache.kafka.common.TopicPartition partition

Class org.springframework.kafka.event.ConsumerPartitionResumedEvent

class ConsumerPartitionResumedEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

partition

org.apache.kafka.common.TopicPartition partition

Class org.springframework.kafka.event.ConsumerPausedEvent

class ConsumerPausedEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

reason

String reason

Class org.springframework.kafka.event.ConsumerResumedEvent

class ConsumerResumedEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Class org.springframework.kafka.event.ConsumerRetryAuthEvent

class ConsumerRetryAuthEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

reason

ConsumerRetryAuthEvent.Reason reason

Class org.springframework.kafka.event.ConsumerRetryAuthSuccessfulEvent

class ConsumerRetryAuthSuccessfulEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Class org.springframework.kafka.event.ConsumerStartedEvent

class ConsumerStartedEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Class org.springframework.kafka.event.ConsumerStartingEvent

class ConsumerStartingEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Class org.springframework.kafka.event.ConsumerStoppedEvent

class ConsumerStoppedEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

reason

ConsumerStoppedEvent.Reason reason

Class org.springframework.kafka.event.ConsumerStoppingEvent

class ConsumerStoppingEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Class org.springframework.kafka.event.ContainerStoppedEvent

class ContainerStoppedEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Class org.springframework.kafka.event.KafkaEvent

class KafkaEvent extends ApplicationEvent implements Serializable

serialVersionUID:

1L

Class org.springframework.kafka.event.ListenerContainerIdleEvent

class ListenerContainerIdleEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

idleTime

long idleTime

listenerId

String listenerId

paused

boolean paused

Class org.springframework.kafka.event.ListenerContainerNoLongerIdleEvent

class ListenerContainerNoLongerIdleEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

idleTime

long idleTime

listenerId

String listenerId

Class org.springframework.kafka.event.ListenerContainerPartitionIdleEvent

class ListenerContainerPartitionIdleEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

idleTime

long idleTime

listenerId

String listenerId

paused

boolean paused

topicPartition

org.apache.kafka.common.TopicPartition topicPartition

Class org.springframework.kafka.event.ListenerContainerPartitionNoLongerIdleEvent

class ListenerContainerPartitionNoLongerIdleEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

idleTime

long idleTime

listenerId

String listenerId

topicPartition

org.apache.kafka.common.TopicPartition topicPartition

Class org.springframework.kafka.event.NonResponsiveConsumerEvent

class NonResponsiveConsumerEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

listenerId

String listenerId

timeSinceLastPoll

long timeSinceLastPoll

topicPartitions

List<org.apache.kafka.common.TopicPartition> topicPartitions

Package org.springframework.kafka.listener

Exception org.springframework.kafka.listener.BatchListenerFailedException

class BatchListenerFailedException extends KafkaException implements Serializable

serialVersionUID:

1L

Serialized Fields

index

int index

Exception org.springframework.kafka.listener.KafkaBackoffException

class KafkaBackoffException extends KafkaException implements Serializable

serialVersionUID:

1L

Serialized Fields

dueTimestamp

long dueTimestamp

listenerId

String listenerId

topicPartition

org.apache.kafka.common.TopicPartition topicPartition

Exception org.springframework.kafka.listener.ListenerExecutionFailedException

class ListenerExecutionFailedException extends KafkaException implements Serializable

Serialized Fields

groupId

String groupId

Exception org.springframework.kafka.listener.TimestampedException

class TimestampedException extends KafkaException implements Serializable

serialVersionUID:

-2544217643924234282L

Serialized Fields

timestamp

long timestamp

Package org.springframework.kafka.requestreply

Exception org.springframework.kafka.requestreply.KafkaReplyTimeoutException

class KafkaReplyTimeoutException extends KafkaException implements Serializable

serialVersionUID:

1L

Package org.springframework.kafka.support

Class org.springframework.kafka.support.JacksonMimeTypeModule

class JacksonMimeTypeModule extends com.fasterxml.jackson.databind.module.SimpleModule implements Serializable

serialVersionUID:

1L

Package org.springframework.kafka.support.converter

Exception org.springframework.kafka.support.converter.ConversionException

class ConversionException extends KafkaException implements Serializable

Class org.springframework.kafka.support.converter.KafkaMessageHeaders

class KafkaMessageHeaders extends MessageHeaders implements Serializable

Package org.springframework.kafka.support.serializer

Exception org.springframework.kafka.support.serializer.DeserializationException

class DeserializationException extends KafkaException implements Serializable

Serialized Fields

data

byte[] data

isKey

boolean isKey

Package org.springframework.kafka.transaction

Class org.springframework.kafka.transaction.KafkaTransactionManager

class KafkaTransactionManager extends AbstractPlatformTransactionManager implements Serializable

Serialized Fields

closeTimeout

Duration closeTimeout

producerFactory

ProducerFactory<K,V> producerFactory

transactionIdPrefix

String transactionIdPrefix