Serialized Form

Package org.springframework.kafka

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

Package org.springframework.kafka.core

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

Serialized Fields

producerRecord

org.apache.kafka.clients.producer.ProducerRecord<K,V> producerRecord

Package org.springframework.kafka.event

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

serialVersionUID:

1L

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

serialVersionUID:

1L

Serialized Fields

partitions

java.util.Collection<E> partitions

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

serialVersionUID:

1L

Serialized Fields

partitions

java.util.Collection<E> 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

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

serialVersionUID:

1L

Serialized Fields

partitions

java.util.Collection<E> 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

topicPartitions

java.util.List<E> topicPartitions

paused

boolean paused

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

serialVersionUID:

1L

Serialized Fields

timeSinceLastPoll

long timeSinceLastPoll

listenerId

java.lang.String listenerId

topicPartitions

java.util.List<E> topicPartitions

Package org.springframework.kafka.listener

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

Serialized Fields

groupId

java.lang.String groupId

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

producerFactory

ProducerFactory<K,V> producerFactory

transactionIdPrefix

java.lang.String transactionIdPrefix

closeTimeout

java.time.Duration closeTimeout