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

B

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

Specify the backoff properties for retrying this operation.

backOff(BackOff) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationSupport.BlockingRetriesConfigurer

Set the BackOff that should be used with the blocking retry mechanism.

BackOffHandler - Interface in org.springframework.kafka.listener

Handler for the provided back off time, listener container and exception.

backOffIfNecessary(KafkaConsumerBackoffManager.Context) - Method in class org.springframework.kafka.listener.ContainerPartitionPausingBackOffManager

Backs off if the current time is before the dueTimestamp provided in the KafkaConsumerBackoffManager.Context object.

backOffIfNecessary(KafkaConsumerBackoffManager.Context) - Method in interface org.springframework.kafka.listener.KafkaConsumerBackoffManager

BackOffValuesGenerator - Class in org.springframework.kafka.retrytopic

Generates the backoff values from the provided maxAttempts value and BackOffPolicy.

BackOffValuesGenerator(int, BackOffPolicy) - Constructor for class org.springframework.kafka.retrytopic.BackOffValuesGenerator

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

Override the container factory's batchListener property.

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

Commit the offsets of all records returned by the previous poll after they all have been processed by the listener.

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

The header for a list of Maps of converted native Kafka headers.

BatchAcknowledgingConsumerAwareMessageListener<K,V> - Interface in org.springframework.kafka.listener

Listener for handling a batch of incoming Kafka messages, propagating an acknowledgment handle that recipients can invoke when the message has been processed.

BatchAcknowledgingMessageListener<K,V> - Interface in org.springframework.kafka.listener

Listener for handling a batch of incoming Kafka messages, propagating an acknowledgment handle that recipients can invoke when the message has been processed.

BatchConsumerAwareMessageListener<K,V> - Interface in org.springframework.kafka.listener

Listener for handling a batch of incoming Kafka messages; the list is created from the consumer records object returned by a poll.

BatchInterceptor<K,V> - Interface in org.springframework.kafka.listener

An interceptor for batches of records.

BatchListenerFailedException - Exception in org.springframework.kafka.listener

An exception thrown by user code to inform the framework which record in a batch has failed.

BatchListenerFailedException(String, int) - Constructor for exception org.springframework.kafka.listener.BatchListenerFailedException

Construct an instance with the provided properties.

BatchListenerFailedException(String, Throwable, int) - Constructor for exception org.springframework.kafka.listener.BatchListenerFailedException

Construct an instance with the provided properties.

BatchListenerFailedException(String, Throwable, ConsumerRecord<?, ?>) - Constructor for exception org.springframework.kafka.listener.BatchListenerFailedException

Construct an instance with the provided properties.

BatchListenerFailedException(String, ConsumerRecord<?, ?>) - Constructor for exception org.springframework.kafka.listener.BatchListenerFailedException

Construct an instance with the provided properties.

BatchMessageConverter - Interface in org.springframework.kafka.support.converter

A Kafka-specific Message converter strategy.

BatchMessageListener<K,V> - Interface in org.springframework.kafka.listener

Listener for handling a batch of incoming Kafka messages; the list is created from the consumer records object returned by a poll.

BatchMessagingMessageConverter - Class in org.springframework.kafka.support.converter

A Messaging MessageConverter implementation used with a batch message listener; the consumer record values are extracted into a collection in the message payload.

BatchMessagingMessageConverter() - Constructor for class org.springframework.kafka.support.converter.BatchMessagingMessageConverter

Create an instance that does not convert the record values.

BatchMessagingMessageConverter(RecordMessageConverter) - Constructor for class org.springframework.kafka.support.converter.BatchMessagingMessageConverter

Create an instance that converts record values using the supplied converter.

BatchMessagingMessageListenerAdapter<K,V> - Class in org.springframework.kafka.listener.adapter

A MessageListener adapter that invokes a configurable HandlerAdapter; used when the factory is configured for the listener to receive batches of messages.

BatchMessagingMessageListenerAdapter(Object, Method) - Constructor for class org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter

Create an instance with the provided parameters.

BatchMessagingMessageListenerAdapter(Object, Method, KafkaListenerErrorHandler) - Constructor for class org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter

Create an instance with the provided parameters.

BatchToRecordAdapter<K,V> - Interface in org.springframework.kafka.listener.adapter

An adapter that adapts a batch listener to a record listener method.

BatchToRecordAdapter.Callback<K,V> - Interface in org.springframework.kafka.listener.adapter

A callback for each message.

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

Bean name of the template.

BEAN_NAME - Static variable in interface org.springframework.kafka.test.EmbeddedKafkaBroker

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

A pseudo bean name used in SpEL expressions within this annotation to reference the current bean within which this listener is defined.

before() - Method in class org.springframework.kafka.test.rule.EmbeddedKafkaRule

beforeAll(ExtensionContext) - Method in class org.springframework.kafka.test.condition.LogLevelsCondition

beforeEach(ExtensionContext) - Method in class org.springframework.kafka.test.condition.LogLevelsCondition

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

Seek to the beginning.

beginningOffsets(TopicPartition...) - Method in class org.springframework.kafka.core.reactive.ReactiveKafkaConsumerTemplate

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

BlockingRetriesConfigurer() - Constructor for class org.springframework.kafka.retrytopic.RetryTopicConfigurationSupport.BlockingRetriesConfigurer

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

The property name to set with the bootstrap server addresses as well as the default "spring.embedded.kafka.brokers".

bounce(BrokerAddress) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker

branch(Predicate<? super K, ? super V>, Consumer<? super KStream<K, V>>) - Method in class org.springframework.kafka.support.KafkaStreamBrancher

Defines a new branch.

BROKER_LIST_PROPERTY - Static variable in interface org.springframework.kafka.test.EmbeddedKafkaBroker

Set the value of this property to a property name that should be set to the list of embedded broker addresses instead of "spring.embedded.kafka.brokers".

BROKER_LIST_PROPERTY - Static variable in class org.springframework.kafka.test.EmbeddedKafkaKraftBroker

Set the value of this property to a property name that should be set to the list of embedded broker addresses instead of "spring.embedded.kafka.brokers".

BROKER_NEEDED - Static variable in interface org.springframework.kafka.test.EmbeddedKafkaBroker

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

The location for a properties file with Kafka broker configuration.

BrokerAddress - Class in org.springframework.kafka.test.core

Encapsulates the address of a Kafka broker.

BrokerAddress(String) - Constructor for class org.springframework.kafka.test.core.BrokerAddress

BrokerAddress(String, int) - Constructor for class org.springframework.kafka.test.core.BrokerAddress

BrokerAddress(BrokerEndPoint) - Constructor for class org.springframework.kafka.test.core.BrokerAddress

brokerListProperty(String) - Method in interface org.springframework.kafka.test.EmbeddedKafkaBroker

Set the system property with this name to the list of broker addresses.

brokerListProperty(String) - Method in class org.springframework.kafka.test.EmbeddedKafkaKraftBroker

Set the system property with this name to the list of broker addresses.

brokerListProperty(String) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker

Set the system property with this name to the list of broker addresses.

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

Properties in form key=value that should be added to the broker config before runs.

brokerProperties(Map<String, String>) - Method in interface org.springframework.kafka.test.EmbeddedKafkaBroker

Specify the properties to configure Kafka Broker before start, e.g.

brokerProperties(Map<String, String>) - Method in class org.springframework.kafka.test.EmbeddedKafkaKraftBroker

Specify the properties to configure Kafka Broker before start, e.g.

brokerProperties(Map<String, String>) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker

Specify the properties to configure Kafka Broker before start, e.g.

brokerProperties(Map<String, String>) - Method in class org.springframework.kafka.test.rule.EmbeddedKafkaRule

Specify the properties to configure Kafka Broker before start, e.g.

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

Spring Resource url specifying the location of properties that should be added to the broker config.

brokerProperty(String, Object) - Method in class org.springframework.kafka.test.EmbeddedKafkaKraftBroker

Specify a broker property.

brokerProperty(String, Object) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker

Specify a broker property.

brokerProperty(String, Object) - Method in class org.springframework.kafka.test.rule.EmbeddedKafkaRule

Specify a broker property.

build() - Method in class org.springframework.kafka.config.TopicBuilder

build() - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.Builder.ExceptionInfo

Builds the Header Names, asserting that none of them is null.

build(Map<String, ?>, boolean, String, Object, Pattern) - Method in class org.springframework.kafka.support.serializer.DelegatingByTopicSerialization

buildConsumerRecordMetadata(Object) - Static method in class org.springframework.kafka.listener.adapter.AdapterUtils

Build a ConsumerRecordMetadata from data which must be a ConsumerRecord.

buildConsumerRecordMetadataFromArray(Object...) - Static method in class org.springframework.kafka.listener.adapter.AdapterUtils

Build a ConsumerRecordMetadata from the first ConsumerRecord in data, if any.

buildDefault(Map<String, ?>, String, boolean, Object) - Method in class org.springframework.kafka.support.serializer.DelegatingByTopicSerialization

Builder() - Constructor for class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.Builder

ByteArrayJsonMessageConverter - Class in org.springframework.kafka.support.converter

JSON Message converter - byte[] on output, String, Bytes, or byte[] on input.

ByteArrayJsonMessageConverter() - Constructor for class org.springframework.kafka.support.converter.ByteArrayJsonMessageConverter

ByteArrayJsonMessageConverter(ObjectMapper) - Constructor for class org.springframework.kafka.support.converter.ByteArrayJsonMessageConverter

byteArrayToDeserializationException(LogAccessor, Header) - Static method in class org.springframework.kafka.support.serializer.SerializationUtils

Convert a byte array containing a serialized DeserializationException to the DeserializationException.

BytesJsonMessageConverter - Class in org.springframework.kafka.support.converter

JSON Message converter - Bytes on output, String, Bytes, or byte[] on input.

BytesJsonMessageConverter() - Constructor for class org.springframework.kafka.support.converter.BytesJsonMessageConverter

BytesJsonMessageConverter(ObjectMapper) - Constructor for class org.springframework.kafka.support.converter.BytesJsonMessageConverter

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