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
-
-
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
-
Serialized Fields
-
message
org.springframework.messaging.Message<?> message
-
record
org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record
-
records
java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records
-
-
-
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
-
-
-