Serialized Form

Package org.springframework.kafka

Class org.springframework.kafka.KafkaException extends org.springframework.core.NestedRuntimeException implements Serializable

Serialized Fields

logLevel

KafkaException.Level logLevel

Package org.springframework.kafka.core

Class org.springframework.kafka.core.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 extends KafkaEvent implements Serializable

serialVersionUID:

1L

Class org.springframework.kafka.event.ConsumerPartitionPausedEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

partition

org.apache.kafka.common.TopicPartition partition

Class org.springframework.kafka.event.ConsumerPartitionResumedEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

partition

org.apache.kafka.common.TopicPartition partition

Class org.springframework.kafka.event.ConsumerPausedEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

partitions

java.util.Collection<org.apache.kafka.common.TopicPartition> partitions

reason

java.lang.String reason

Class org.springframework.kafka.event.ConsumerResumedEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

partitions

java.util.Collection<org.apache.kafka.common.TopicPartition> partitions

Class org.springframework.kafka.event.ConsumerStartedEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Class org.springframework.kafka.event.ConsumerStartingEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Class org.springframework.kafka.event.ConsumerStoppedEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

reason

ConsumerStoppedEvent.Reason reason

Class org.springframework.kafka.event.ConsumerStoppingEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

partitions

java.util.Collection<org.apache.kafka.common.TopicPartition> partitions

Class org.springframework.kafka.event.ContainerStoppedEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Class org.springframework.kafka.event.KafkaEvent extends org.springframework.context.ApplicationEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

container

java.lang.Object container

Class org.springframework.kafka.event.ListenerContainerIdleEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

idleTime

long idleTime

listenerId

java.lang.String listenerId

paused

boolean paused

topicPartitions

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

Class org.springframework.kafka.event.ListenerContainerNoLongerIdleEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

idleTime

long idleTime

listenerId

java.lang.String listenerId

topicPartitions

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

Class org.springframework.kafka.event.ListenerContainerPartitionIdleEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

idleTime

long idleTime

listenerId

java.lang.String listenerId

paused

boolean paused

topicPartition

org.apache.kafka.common.TopicPartition topicPartition

Class org.springframework.kafka.event.ListenerContainerPartitionNoLongerIdleEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

idleTime

long idleTime

listenerId

java.lang.String listenerId

topicPartition

org.apache.kafka.common.TopicPartition topicPartition

Class org.springframework.kafka.event.NonResponsiveConsumerEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

listenerId

java.lang.String listenerId

timeSinceLastPoll

long timeSinceLastPoll

topicPartitions

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

Package org.springframework.kafka.listener

Class org.springframework.kafka.listener.BatchListenerFailedException extends KafkaException implements Serializable

serialVersionUID:

1L

Serialized Fields

index

int index

record

org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record

Class org.springframework.kafka.listener.KafkaBackoffException extends KafkaException implements Serializable

serialVersionUID:

1L

Serialized Fields

dueTimestamp

long dueTimestamp

listenerId

java.lang.String listenerId

topicPartition

org.apache.kafka.common.TopicPartition topicPartition

Class org.springframework.kafka.listener.ListenerExecutionFailedException extends KafkaException implements Serializable

Serialized Fields

groupId

java.lang.String groupId

Class org.springframework.kafka.listener.TimestampedException extends KafkaException implements Serializable

serialVersionUID:

-2544217643924234282L

Serialized Fields

timestamp

long timestamp

Package org.springframework.kafka.requestreply

Class org.springframework.kafka.requestreply.KafkaReplyTimeoutException extends KafkaException implements Serializable

serialVersionUID:

1L

Package org.springframework.kafka.support

Class org.springframework.kafka.support.JacksonMimeTypeModule extends com.fasterxml.jackson.databind.module.SimpleModule implements Serializable

serialVersionUID:

1L

Package org.springframework.kafka.support.converter

Class org.springframework.kafka.support.converter.ConversionException extends KafkaException implements Serializable

Class org.springframework.kafka.support.converter.KafkaMessageHeaders extends org.springframework.messaging.MessageHeaders implements Serializable

Package org.springframework.kafka.support.serializer

Class org.springframework.kafka.support.serializer.DeserializationException extends KafkaException implements Serializable

Serialized Fields

data

byte[] data

isKey

boolean isKey

Package org.springframework.kafka.transaction

Class org.springframework.kafka.transaction.KafkaTransactionManager extends org.springframework.transaction.support.AbstractPlatformTransactionManager implements Serializable

Serialized Fields

closeTimeout

java.time.Duration closeTimeout

producerFactory

ProducerFactory<K,V> producerFactory

transactionIdPrefix

java.lang.String transactionIdPrefix