Index

A B C D E F G H I J K L M N O P R S T U V W Z
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

T

tags - Variable in class org.springframework.kafka.core.KafkaMetricsSupport

targetType - Variable in class org.springframework.kafka.support.serializer.JsonDeserializer

TEMPLATE_OBSERVATION - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaTemplateObservation

Observation for KafkaTemplates.

testPlanExecutionFinished(TestPlan) - Method in class org.springframework.kafka.test.junit.GlobalEmbeddedKafkaTestExecutionListener

testPlanExecutionStarted(TestPlan) - Method in class org.springframework.kafka.test.junit.GlobalEmbeddedKafkaTestExecutionListener

ThreadStateProcessor - Interface in org.springframework.kafka.listener

A general interface for managing thread-bound resources when a Consumer is available.

TIME - Enum constant in enum class org.springframework.kafka.listener.ContainerProperties.AckMode

Commit pending offsets after ackTime has elapsed.

timeout() - Element in annotation interface org.springframework.kafka.annotation.RetryableTopic

The amount of time in milliseconds after which message retrying should give up and send the message to the DLT.

timeoutAfter(long) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder

Configure a global timeout, in milliseconds, after which a record will go straight to the DLT the next time a listener throws an exception.

timestamp() - Method in class org.springframework.kafka.listener.adapter.ConsumerRecordMetadata

timestamp(long) - Static method in class org.springframework.kafka.test.assertj.KafkaConditions

timestamp(TimestampType, long) - Static method in class org.springframework.kafka.test.assertj.KafkaConditions

TIMESTAMP - Enum constant in enum class org.springframework.kafka.support.TopicPartitionOffset.SeekPosition

Seek to the time stamp; if no records exist with a timestamp greater than or equal to the timestamp seek to the end.

TIMESTAMP - Static variable in class org.springframework.kafka.support.KafkaHeaders

The header for holding the timestamp of the producer record.

TIMESTAMP_TYPE - Static variable in class org.springframework.kafka.support.KafkaHeaders

The header for holding the type of timestamp.

TimestampedException - Exception in org.springframework.kafka.listener

A KafkaException that records the timestamp of when it was thrown.

TimestampedException(Exception) - Constructor for exception org.springframework.kafka.listener.TimestampedException

Constructs an instance with the provided cause and the current time.

TimestampedException(Exception, long) - Constructor for exception org.springframework.kafka.listener.TimestampedException

Creates an instance with the timestamp of when it was thrown and its cause.

TimestampedException(Exception, Instant) - Constructor for exception org.springframework.kafka.listener.TimestampedException

Creates an instance with the Instant of when it was thrown and its cause.

timestampHeader(String) - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.Builder.Original

Sets the name of the header that will be used to store the timestamp of the original record.

timestampType() - Method in class org.springframework.kafka.listener.adapter.ConsumerRecordMetadata

timestampTypeHeader(String) - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.Builder.Original

Sets the name of the header that will be used to store the timestampType of the original record.

toClass(Headers) - Method in interface org.springframework.kafka.support.mapping.ClassMapper

toClass(Headers) - Method in class org.springframework.kafka.support.mapping.DefaultJackson2JavaTypeMapper

ToFromStringSerde<T> - Class in org.springframework.kafka.support.serializer

A Serde that delegates to a ToStringSerializer and ParseStringDeserializer.

ToFromStringSerde(ToStringSerializer<T>, ParseStringDeserializer<T>) - Constructor for class org.springframework.kafka.support.serializer.ToFromStringSerde

Construct an instance with the provided properties.

toHeaders(Headers, Map<String, Object>) - Method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper

toHeaders(Headers, Map<String, Object>) - Method in interface org.springframework.kafka.support.KafkaHeaderMapper

Map from the given native headers to a map of headers for the eventual MessageHeaders.

toHeaders(Headers, Map<String, Object>) - Method in class org.springframework.kafka.support.SimpleKafkaHeaderMapper

toJavaType(Headers) - Method in class org.springframework.kafka.support.mapping.DefaultJackson2JavaTypeMapper

toJavaType(Headers) - Method in interface org.springframework.kafka.support.mapping.Jackson2JavaTypeMapper

toMessage(List<ConsumerRecord<?, ?>>, Acknowledgment, Consumer<?, ?>, Type) - Method in interface org.springframework.kafka.support.converter.BatchMessageConverter

Convert a list of ConsumerRecord to a Message.

toMessage(List<ConsumerRecord<?, ?>>, Acknowledgment, Consumer<?, ?>, Type) - Method in class org.springframework.kafka.support.converter.BatchMessagingMessageConverter

toMessage(ConsumerRecord<?, ?>, Acknowledgment, Consumer<?, ?>, Type) - Method in class org.springframework.kafka.support.converter.MessagingMessageConverter

toMessage(ConsumerRecord<?, ?>, Acknowledgment, Consumer<?, ?>, Type) - Method in interface org.springframework.kafka.support.converter.RecordMessageConverter

Convert a ConsumerRecord to a Message.

toMessagingMessage(List, Acknowledgment, Consumer<?, ?>) - Method in class org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter

toMessagingMessage(ConsumerRecord<K, V>, Acknowledgment, Consumer<?, ?>) - Method in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter

topic() - Element in annotation interface org.springframework.kafka.annotation.TopicPartition

The topic to listen on.

topic() - Method in class org.springframework.kafka.listener.adapter.ConsumerRecordMetadata

TOPIC - Enum constant in enum class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.HeadersToAdd

The original topic of the failed record.

TOPIC - Static variable in class org.springframework.kafka.support.KafkaHeaders

The header containing the topic when sending data to Kafka.

TopicBuilder - Class in org.springframework.kafka.config

Builder for a NewTopic.

TopicForRetryable - Class in org.springframework.kafka.support

Marker to indicate this NewTopic is for retryable topics; admin will ignore these if a regular NewTopic exist.

TopicForRetryable(String, int, short) - Constructor for class org.springframework.kafka.support.TopicForRetryable

Create an instance with the provided properties.

topicHeader(String) - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.Builder.Original

Sets the name of the header that will be used to store the topic of the original record.

TopicPartition - Annotation Interface in org.springframework.kafka.annotation

Used to add topic/partition information to a KafkaListener.

TopicPartitionOffset - Class in org.springframework.kafka.support

A configuration container to represent a topic name, partition number and, optionally, an offset for it.

TopicPartitionOffset(String, int) - Constructor for class org.springframework.kafka.support.TopicPartitionOffset

Construct an instance with no initial offset management.

TopicPartitionOffset(String, int, Long) - Constructor for class org.springframework.kafka.support.TopicPartitionOffset

Construct an instance with the provided initial offset with TopicPartitionOffset.isRelativeToCurrent() false.

TopicPartitionOffset(String, int, Long, boolean) - Constructor for class org.springframework.kafka.support.TopicPartitionOffset

Construct an instance with the provided initial offset.

TopicPartitionOffset(String, int, Long, TopicPartitionOffset.SeekPosition) - Constructor for class org.springframework.kafka.support.TopicPartitionOffset

Construct an instance with the provided TopicPartitionOffset.SeekPosition.

TopicPartitionOffset(String, int, Function<Long, Long>) - Constructor for class org.springframework.kafka.support.TopicPartitionOffset

Construct an instance with the provided function to compute the offset.

TopicPartitionOffset(String, int, TopicPartitionOffset.SeekPosition) - Constructor for class org.springframework.kafka.support.TopicPartitionOffset

Construct an instance with the provided TopicPartitionOffset.SeekPosition.

TopicPartitionOffset(TopicPartition, Long, TopicPartitionOffset.SeekPosition) - Constructor for class org.springframework.kafka.support.TopicPartitionOffset

Construct an instance with the provided TopicPartitionOffset.SeekPosition.

TopicPartitionOffset.SeekPosition - Enum Class in org.springframework.kafka.support

Enumeration for "special" seeks.

topicPartitions() - Element in annotation interface org.springframework.kafka.annotation.KafkaListener

The topicPartitions for this listener when using manual topic/partition assignment.

topicPattern() - Element in annotation interface org.springframework.kafka.annotation.KafkaListener

The topic pattern for this listener.

topics() - Element in annotation interface org.springframework.kafka.annotation.KafkaListener

The topics for this listener.

topics() - Element in annotation interface org.springframework.kafka.test.context.EmbeddedKafka

Topics that should be created Topics may contain property place holders, e.g.

TOPICS_PROPERTY_NAME - Static variable in class org.springframework.kafka.test.junit.GlobalEmbeddedKafkaTestExecutionListener

The topics to create on the embedded broker(s).

topicSuffixingStrategy() - Element in annotation interface org.springframework.kafka.annotation.RetryableTopic

Whether the retry topics will be suffixed with the delay value for that topic or a simple index.

TopicSuffixingStrategy - Enum Class in org.springframework.kafka.retrytopic

Constants for the RetryTopic functionality.

toString() - Method in class org.springframework.kafka.config.AbstractKafkaListenerEndpoint

toString() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory.CloseSafeProducer

toString() - Method in class org.springframework.kafka.event.ConcurrentContainerStoppedEvent

toString() - Method in class org.springframework.kafka.event.ConsumerFailedToStartEvent

toString() - Method in class org.springframework.kafka.event.ConsumerPartitionPausedEvent

toString() - Method in class org.springframework.kafka.event.ConsumerPartitionResumedEvent

toString() - Method in class org.springframework.kafka.event.ConsumerPausedEvent

toString() - Method in class org.springframework.kafka.event.ConsumerResumedEvent

toString() - Method in class org.springframework.kafka.event.ConsumerRetryAuthEvent

toString() - Method in class org.springframework.kafka.event.ConsumerRetryAuthSuccessfulEvent

toString() - Method in class org.springframework.kafka.event.ConsumerStartedEvent

toString() - Method in class org.springframework.kafka.event.ConsumerStartingEvent

toString() - Method in class org.springframework.kafka.event.ConsumerStoppedEvent

toString() - Method in class org.springframework.kafka.event.ConsumerStoppingEvent

toString() - Method in class org.springframework.kafka.event.ContainerStoppedEvent

toString() - Method in class org.springframework.kafka.event.ListenerContainerIdleEvent

toString() - Method in class org.springframework.kafka.event.ListenerContainerNoLongerIdleEvent

toString() - Method in class org.springframework.kafka.event.ListenerContainerPartitionIdleEvent

toString() - Method in class org.springframework.kafka.event.ListenerContainerPartitionNoLongerIdleEvent

toString() - Method in class org.springframework.kafka.event.NonResponsiveConsumerEvent

toString() - Method in class org.springframework.kafka.listener.adapter.ConsumerRecordMetadata

toString() - Method in record class org.springframework.kafka.listener.adapter.InvocationResult

Returns a string representation of this record class.

toString() - Method in record class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.ReplyExpressionRoot

Returns a string representation of this record class.

toString() - Method in class org.springframework.kafka.listener.ConcurrentMessageListenerContainer

toString() - Method in class org.springframework.kafka.listener.ConsumerProperties

toString() - Method in class org.springframework.kafka.listener.ContainerGroup

toString() - Method in class org.springframework.kafka.listener.ContainerProperties

toString() - Method in class org.springframework.kafka.listener.KafkaMessageListenerContainer

toString() - Method in class org.springframework.kafka.requestreply.CorrelationKey

toString() - Method in class org.springframework.kafka.retrytopic.DestinationTopic.Properties

toString() - Method in class org.springframework.kafka.retrytopic.DestinationTopic

toString() - Method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper.NonTrustedHeaderType

toString() - Method in class org.springframework.kafka.support.SendResult

toString() - Method in class org.springframework.kafka.support.serializer.FailedDeserializationInfo

toString() - Method in class org.springframework.kafka.support.TopicPartitionOffset

toString() - Method in class org.springframework.kafka.test.core.BrokerAddress

ToStringSerializer<T> - Class in org.springframework.kafka.support.serializer

Generic Serializer that relies on Object.toString() to get serialized representation of the entity.

ToStringSerializer() - Constructor for class org.springframework.kafka.support.serializer.ToStringSerializer

TRACE - Enum constant in enum class org.springframework.kafka.KafkaException.Level

Trace.

TRACE - Enum constant in enum class org.springframework.kafka.support.LogIfLevelEnabled.Level

Trace.

transactionCapable() - Method in class org.springframework.kafka.core.DefaultKafkaProducerFactory

transactionCapable() - Method in interface org.springframework.kafka.core.ProducerFactory

Return true if the factory supports transactions.

transactionCapable() - Method in class org.springframework.kafka.mock.MockProducerFactory

TransactionIdSuffixStrategy - Interface in org.springframework.kafka.core

The strategy for managing transactional producer suffixes.

transactionManager() - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate

traversingCauses() - Element in annotation interface org.springframework.kafka.annotation.RetryableTopic

Whether or not the captured exception should be traversed to look for the exceptions provided above.

traversingCauses() - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder

Configure the classifier to traverse the cause chain.

traversingCauses(boolean) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder

Configure the classifier to traverse, or not, the cause chain.

trusted(String) - Method in class org.springframework.kafka.support.DefaultKafkaHeaderMapper

TRUSTED_PACKAGES - Static variable in class org.springframework.kafka.support.serializer.JsonDeserializer

Kafka config property for trusted deserialization packages.

trustedPackages(String...) - Method in class org.springframework.kafka.support.serializer.JsonDeserializer

Add trusted packages to the default type mapper.

TS - Enum constant in enum class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.HeadersToAdd

The timestamp of the failed record.

TS_TYPE - Enum constant in enum class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.HeadersToAdd

The timestamp type of the failed record.

TYPE_ID - Enum constant in enum class org.springframework.kafka.support.mapping.Jackson2JavaTypeMapper.TypePrecedence

The type is obtained from headers.

TYPE_MAPPINGS - Static variable in class org.springframework.kafka.support.serializer.JsonDeserializer

Kafka config property to add type mappings to the type mapper: 'foo=com.Foo,bar=com.Bar'.

TYPE_MAPPINGS - Static variable in class org.springframework.kafka.support.serializer.JsonSerializer

Kafka config property to add type mappings to the type mapper: 'foo:com.Foo,bar:com.Bar'.

typeFunction(BiFunction<byte[], Headers, JavaType>) - Method in class org.springframework.kafka.support.serializer.JsonDeserializer

Set a BiFunction that receives the data to be deserialized and the headers and returns a JavaType.

typeMapper - Variable in class org.springframework.kafka.support.serializer.JsonDeserializer

typeMapper - Variable in class org.springframework.kafka.support.serializer.JsonSerializer

typeMapper(Jackson2JavaTypeMapper) - Method in class org.springframework.kafka.support.serializer.JsonDeserializer

Use the supplied Jackson2JavaTypeMapper.

typeMapper(Jackson2JavaTypeMapper) - Method in class org.springframework.kafka.support.serializer.JsonSerde

Use the supplied Jackson2JavaTypeMapper.

typeMapper(Jackson2JavaTypeMapper) - Method in class org.springframework.kafka.support.serializer.JsonSerializer

Use the supplied Jackson2JavaTypeMapper.

typeResolver(JsonTypeResolver) - Method in class org.springframework.kafka.support.serializer.JsonDeserializer

Set a JsonTypeResolver that receives the data to be deserialized and the headers and returns a JavaType.

A B C D E F G H I J K L M N O P R S T U V W Z
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form