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

E

EmbeddedKafka - Annotation Interface in org.springframework.kafka.test.context

Annotation that can be specified on a test class that runs Spring for Apache Kafka based tests.

EmbeddedKafkaBroker - Interface in org.springframework.kafka.test

EmbeddedKafkaCondition - Class in org.springframework.kafka.test.condition

JUnit5 condition for an embedded broker.

EmbeddedKafkaCondition() - Constructor for class org.springframework.kafka.test.condition.EmbeddedKafkaCondition

EmbeddedKafkaKraftBroker - Class in org.springframework.kafka.test

An embedded Kafka Broker(s) using KRaft.

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

Create embedded Kafka brokers listening on random ports.

EmbeddedKafkaRule - Class in org.springframework.kafka.test.rule

A TestRule wrapper around an EmbeddedKafkaBroker.

EmbeddedKafkaRule(int) - Constructor for class org.springframework.kafka.test.rule.EmbeddedKafkaRule

EmbeddedKafkaRule(int, boolean, int, String...) - Constructor for class org.springframework.kafka.test.rule.EmbeddedKafkaRule

Create embedded Kafka brokers listening on random ports.

EmbeddedKafkaRule(int, boolean, String...) - Constructor for class org.springframework.kafka.test.rule.EmbeddedKafkaRule

Create embedded Kafka brokers.

EmbeddedKafkaZKBroker - Class in org.springframework.kafka.test

An embedded Kafka Broker(s) and Zookeeper manager.

EmbeddedKafkaZKBroker(int) - Constructor for class org.springframework.kafka.test.EmbeddedKafkaZKBroker

EmbeddedKafkaZKBroker(int, boolean, int, String...) - Constructor for class org.springframework.kafka.test.EmbeddedKafkaZKBroker

Create embedded Kafka brokers listening on random ports.

EmbeddedKafkaZKBroker(int, boolean, String...) - Constructor for class org.springframework.kafka.test.EmbeddedKafkaZKBroker

Create embedded Kafka brokers.

EmbeddedKafkaZKBroker.EmbeddedZookeeper - Class in org.springframework.kafka.test

Ported from scala to allow setting the port.

EmbeddedZookeeper(int) - Constructor for class org.springframework.kafka.test.EmbeddedKafkaZKBroker.EmbeddedZookeeper

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

Enable Kafka listener annotated endpoints that are created under the covers by a AbstractListenerContainerFactory.

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

Enables the non-blocking topic-based delayed retries feature.

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

Enable default Kafka Streams components.

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

Seek to the end.

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

EndpointCustomizer - Interface in org.springframework.kafka.retrytopic

Customizes main, retry and DLT endpoints in the Retry Topic functionality and returns the resulting topic names.

EndpointCustomizer.TopicNamesHolder - Class in org.springframework.kafka.retrytopic

EndpointCustomizerFactory - Class in org.springframework.kafka.retrytopic

Creates the EndpointCustomizer that will be used by the RetryTopicConfigurer to customize the main, retry and DLT endpoints.

EndpointCustomizerFactory(DestinationTopic.Properties, EndpointHandlerMethod, BeanFactory, RetryTopicNamesProviderFactory) - Constructor for class org.springframework.kafka.retrytopic.EndpointCustomizerFactory

EndpointHandlerMethod - Class in org.springframework.kafka.support

Handler method for retrying endpoints.

EndpointHandlerMethod(Object, Method) - Constructor for class org.springframework.kafka.support.EndpointHandlerMethod

EndpointHandlerMethod(Object, String) - Constructor for class org.springframework.kafka.support.EndpointHandlerMethod

enhancedObjectMapper() - Static method in class org.springframework.kafka.support.JacksonUtils

Factory for ObjectMapper instances with registered well-known modules and disabled MapperFeature.DEFAULT_VIEW_INCLUSION and DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES features.

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

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

Indicates whether some other object is "equal to" this one.

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

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

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

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

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

ERROR - Enum constant in enum class org.springframework.kafka.event.ConsumerStoppedEvent.Reason

A Error was thrown.

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

Error.

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

Error.

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

Set an KafkaListenerErrorHandler bean name to invoke if the listener method throws an exception.

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

Delegating key/value deserializer that catches exceptions, returning them in the headers as serialized java objects.

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

ErrorHandlingDeserializer(Deserializer<T>) - Constructor for class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer

ErrorHandlingUtils - Class in org.springframework.kafka.listener

Utilities for error handling.

evaluateExecutionCondition(ExtensionContext) - Method in class org.springframework.kafka.test.condition.EmbeddedKafkaCondition

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

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

The exception cause class name.

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

The exception message.

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

The exception stack trace.

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

Returns the exception builder.

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

The exception class name.

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

Exception class name for a record published sent to another topic.

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

Exception class name for a record published sent to another topic.

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

Exception message for a record published to another topic.

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

Exception stack trace for a record published to another topic.

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

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

ExceptionClassifier - Class in org.springframework.kafka.listener

Supports exception classification.

ExceptionClassifier() - Constructor for class org.springframework.kafka.listener.ExceptionClassifier

Construct the instance.

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

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

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

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

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

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

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

exchange(Message<?>) - Method in interface org.springframework.kafka.streams.messaging.MessagingFunction

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

The exception types that should not be retried.

excludeHeader(DeadLetterPublishingRecoverer.HeaderNames.HeadersToAdd...) - Method in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer

Clear the header inclusion bit for the header name.

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

The exception class names that should not be retried.

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

Configure a topic name for which the target configuration will NOT be used.

excludeTopics(List<String>) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder

Configure the topic names for which the target configuration will NOT be used.

execute(KafkaOperations.ProducerCallback<Object, Object, T>) - Method in class org.springframework.kafka.core.RoutingKafkaTemplate

execute(KafkaOperations.ProducerCallback<K, V, T>) - Method in interface org.springframework.kafka.core.KafkaOperations

Execute some arbitrary operation(s) on the producer and return the result.

execute(KafkaOperations.ProducerCallback<K, V, T>) - Method in class org.springframework.kafka.core.KafkaTemplate

executeInTransaction(KafkaOperations.OperationsCallback<Object, Object, T>) - Method in class org.springframework.kafka.core.RoutingKafkaTemplate

executeInTransaction(KafkaOperations.OperationsCallback<K, V, T>) - Method in interface org.springframework.kafka.core.KafkaOperations

Execute some arbitrary operation(s) on the operations and return the result.

executeInTransaction(KafkaOperations.OperationsCallback<K, V, T>) - Method in class org.springframework.kafka.core.KafkaTemplate

exponentialBackoff(long, double, long) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder

Configure an ExponentialBackOffPolicy.

exponentialBackoff(long, double, long, boolean) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder

Configure an ExponentialBackOffPolicy or ExponentialRandomBackOffPolicy depending on the random parameter.

ExponentialBackOffWithMaxRetries - Class in org.springframework.kafka.support

Subclass of ExponentialBackOff that allows the specification of the maximum number of retries rather than the maximum elapsed time.

ExponentialBackOffWithMaxRetries(int) - Constructor for class org.springframework.kafka.support.ExponentialBackOffWithMaxRetries

Construct an instance that will calculate the ExponentialBackOffWithMaxRetries.setMaxElapsedTime(long) from the maxRetries.

ExtendedKafkaConsumer(Map<String, Object>) - Constructor for class org.springframework.kafka.core.DefaultKafkaConsumerFactory.ExtendedKafkaConsumer

extractAndConvertValue(ConsumerRecord<?, ?>, Type) - Method in class org.springframework.kafka.support.converter.BatchMessagingMessageConverter

Subclasses can convert the value; by default, it's returned as provided by Kafka unless a RecordMessageConverter has been provided.

extractAndConvertValue(ConsumerRecord<?, ?>, Type) - Method in class org.springframework.kafka.support.converter.JsonMessageConverter

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

Subclasses can convert the value; by default, it's returned as provided by Kafka unless there is a SmartMessageConverter that can convert it.

extractAndConvertValue(ConsumerRecord<?, ?>, Type) - Method in class org.springframework.kafka.support.converter.ProjectingMessageConverter

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