インデックス

N

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

バッチ内のインデックスでレコードを否定的に確認します。インデックスの前にレコードのオフセットをコミットし、パーティションを再シークして、インデックスのレコードと後続のレコードがスリープ期間後に再配信されるようにします。

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

現在のレコードを否定的に確認します。ポーリングから残りのレコードを破棄し、すべてのパーティションを再シークして、スリープ期間後にこのレコードが再配信されるようにします。

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

指定された名前で TopicBuilder を作成します。

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

コンシューマーレコードのネイティブヘッダーを保持するためのヘッダー。ヘッダーマッパーが存在しない場合にのみ提供されます。

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

パーティションの割り当て中に現在のオフセットをコミットしないでください。

neverLogListenerException() - クラス org.springframework.kafka.retrytopic のメソッド。DeadLetterPublishingRecovererFactory

リスナー例外をログに記録しないでください。

NeverMatchHeaderMatcher(String...) - クラス org.springframework.kafka.support のコンストラクター。AbstractKafkaHeaderMapper.NeverMatchHeaderMatcher

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

ビルダーの新しいインスタンスを作成します。

newTopics() - クラス org.springframework.kafka.core のメソッド。KafkaAdmin

作成または変更する NewTopic のコレクションを返します。

NewTopics(NewTopic...) - クラス org.springframework.kafka.core のコンストラクター。KafkaAdmin.NewTopics

NewTopic を使用してインスタンスを作成します。

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

DLT を作成しないでください。

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

パーティションのオフセットが見つからず、リセットポリシーもありません。

noBackoff() - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder

NoBackOffPolicy を構成します。

noBeanFoundMessage(Object, String, String, Class<?>) - クラス org.springframework.kafka.annotation のメソッド。KafkaListenerAnnotationBeanPostProcessor

NonResponsiveConsumerEvent - org.springframework.kafka.event のクラス

コンシューマーが投票に応答していないときに発行されるイベント。kafka-clients の初期バージョンでは、これはブローカーがダウンしていることを示している可能性があります。

NonResponsiveConsumerEvent(Object, Object, long, String, Collection<TopicPartition>, Consumer<?, ?>) - クラス org.springframework.kafka.event. NonResponsiveConsumerEvent のコンストラクター

提供されたプロパティを使用してインスタンスを構築します。

NonTrustedHeaderType() - クラス org.springframework.kafka.support のコンストラクター。DefaultKafkaHeaderMapper.NonTrustedHeaderType

NoProducerAvailableException - Exception in org.springframework.kafka.core

プロデューサーが利用できない場合の例外。

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

指定された詳細メッセージを持つ新しいプロデューサーが利用できない例外を構築します。

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

コンテナーが停止したため、コンシューマーは停止しました。

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

integer プロパティが設定されていないことを表す定数。

notRetryable(Stream<Class<? extends Exception>>) - クラス org.springframework.kafka.listener のメソッド。ExceptionClassifier

サブクラスはこれをオーバーライドして、再試行不可能な例外の構成の通知を受け取ることができます。

notRetryable(Stream<Class<? extends Exception>>) - クラス org.springframework.kafka.listener のメソッド。FailedBatchProcessor

notRetryOn(Class<? extends Throwable>) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder

提供された ThrowableSE で再試行しないように動作を構成します。

notRetryOn(List<Class<? extends Throwable>>) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder

提供された ThrowableSE で再試行しないように動作を構成します。

noTypeInfo() - クラス org.springframework.kafka.support.serializer のメソッド。JsonSerde

型情報を追加しないようにシリアライザーを構成します。

noTypeInfo() - クラス org.springframework.kafka.support.serializer のメソッド。JsonSerializer

型情報ヘッダーを含めないでください。

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

変換が不要な場合に使用されるメッセージ。

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

自動的に作成されたトピックのパーティションの数。

numPartitions() - クラス org.springframework.kafka.retrytopic のメソッド。DestinationTopic.Properties

再試行トピックを作成する必要のあるパーティションの数を返します。