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

N

nack(int, Duration) - Method in interface org.springframework.kafka.support.Acknowledgment

Negatively acknowledge the record at an index in a batch - commit the offset(s) of records before the index and re-seek the partitions so that the record at the index and subsequent records will be redelivered after the sleep duration.

nack(Duration) - Method in interface org.springframework.kafka.support.Acknowledgment

Negatively acknowledge the current record - discard remaining records from the poll and re-seek all partitions so that this record will be redelivered after the sleep duration.

name(String) - Static method in class org.springframework.kafka.config.TopicBuilder

Create a TopicBuilder with the supplied name.

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

The header for holding the native headers of the consumer record; only provided if no header mapper is present.

NEVER - Enum constant in enum class org.springframework.kafka.listener.ContainerProperties.AssignmentCommitOption

Never commit the current offset during partition assignment.

neverLogListenerException() - Method in class org.springframework.kafka.retrytopic.DeadLetterPublishingRecovererFactory

Never logs the listener exception.

NeverMatchHeaderMatcher(String...) - Constructor for class org.springframework.kafka.support.AbstractKafkaHeaderMapper.NeverMatchHeaderMatcher

newInstance() - Static method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder

Create a new instance of the builder.

newTopics() - Method in class org.springframework.kafka.core.KafkaAdmin

Return a collection of NewTopics to create or modify.

NewTopics(NewTopic...) - Constructor for class org.springframework.kafka.core.KafkaAdmin.NewTopics

Construct an instance with the NewTopics.

NO_DLT - Enum constant in enum class org.springframework.kafka.retrytopic.DltStrategy

Don't create a DLT.

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

No offset found for a partition and no reset policy.

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

Configure a NoBackOffPolicy.

noBeanFoundMessage(Object, String, String, Class<?>) - Method in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor

NonResponsiveConsumerEvent - Class in org.springframework.kafka.event

An event that is emitted when a consumer is not responding to the poll; with early versions of the kafka-clients, this was a possible indication that the broker is down.

NonResponsiveConsumerEvent(Object, Object, long, String, Collection<TopicPartition>, Consumer<?, ?>) - Constructor for class org.springframework.kafka.event.NonResponsiveConsumerEvent

Construct an instance with the provided properties.

NonTrustedHeaderType() - Constructor for class org.springframework.kafka.support.DefaultKafkaHeaderMapper.NonTrustedHeaderType

NoProducerAvailableException - Exception in org.springframework.kafka.core

Exception when no producer is available.

NoProducerAvailableException(String, String) - Constructor for exception org.springframework.kafka.core.NoProducerAvailableException

Constructs a new no producer available exception with the specified detail message.

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

The consumer was stopped because the container was stopped.

NOT_SET - Static variable in class org.springframework.kafka.retrytopic.RetryTopicConstants

Constant to represent that the integer property is not set.

notRetryable(Stream<Class<? extends Exception>>) - Method in class org.springframework.kafka.listener.ExceptionClassifier

Subclasses can override this to receive notification of configuration of not retryable exceptions.

notRetryable(Stream<Class<? extends Exception>>) - Method in class org.springframework.kafka.listener.FailedBatchProcessor

notRetryOn(Class<? extends Throwable>) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder

Configure the behavior to NOT retry on the provided Throwable.

notRetryOn(List<Class<? extends Throwable>>) - Method in class org.springframework.kafka.retrytopic.RetryTopicConfigurationBuilder

Configure the behavior to NOT retry on the provided Throwables.

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

Configure the serializer to not add type information.

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

Do not include type info headers.

NULL_MESSAGE - Static variable in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter

Message used when no conversion is needed.

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

The number of partitions for the automatically created topics.

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

Return the number of partitions the retry topics should be created with.

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