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.ConsumerPausedEvent extends KafkaEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

partitions

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

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

closeTimeout

java.time.Duration closeTimeout

producerFactory

ProducerFactory<K,V> producerFactory

transactionIdPrefix

java.lang.String transactionIdPrefix