インデックス

L

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

auto.offset.reset が 'latest' の場合、パーティション割り当て中に現在のオフセットをコミットします。そのように構成されている場合はトランザクション。

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

auto.offset.reset が 'latest' の場合、パーティション割り当て中に現在のオフセットをコミットします。トランザクションが使用されている場合でも、コンシューマーコミットを使用します。

level() - Element in annotation interface org.springframework.kafka.test.condition.LogLevels

テスト中にカテゴリを切り替える Log4j レベル名。

LevelsContainer(Map<Class<?>, Level>, Map<String, Level>) - クラス org.springframework.kafka.test.utils のコンストラクター。JUnitUtils.LevelsContainer

lifecycleLock - Variable in class org.springframework.kafka.listener.AbstractMessageListenerContainer

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

GlobalEmbeddedKafkaTestExecutionListener を有効にするために使用されるプロパティ名。

LISTENER_ID - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaListenerObservation.ListenerLowCardinalityTags

リスナー ID (またはリスナーコンテナー Bean 名)。

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

このレコードを受信するリスナーに関する任意の静的情報。

LISTENER_OBSERVATION - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaListenerObservation

Apache Kafka リスナーの観察。

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

再試行および dlt トピックのコンシューマーを作成するために使用される ConcurrentKafkaListenerContainerFactory の Bean 名。

listenerContainerFactoryConfigurer(KafkaConsumerBackoffManager, DeadLetterPublishingRecovererFactory, Clock) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicComponentFactory

ListenerContainerFactoryResolver によって解決される KafkaListenerContainerFactory の構成に使用される ListenerContainerFactoryConfigurer を作成します。

ListenerContainerFactoryConfigurer - org.springframework.kafka.retrytopic のクラス

付属の ConcurrentKafkaListenerContainerFactory を装飾して、DefaultErrorHandler と DeadLetterPublishingRecovererFactory によって作成された DeadLetterPublishingRecoverer を追加します。

ListenerContainerFactoryConfigurer(KafkaConsumerBackoffManager, DeadLetterPublishingRecovererFactory, Clock) - クラス org.springframework.kafka.retrytopic. ListenerContainerFactoryConfigurer のコンストラクター

listenerContainerFactoryResolver(BeanFactory) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicComponentFactory

特定のトピックの適切な KafkaListenerContainerFactory を解決するために使用される ListenerContainerFactoryResolver を作成します。

ListenerContainerFactoryResolver - org.springframework.kafka.retrytopic のクラス

RetryTopicConfiguration によって使用される ConcurrentKafkaListenerContainerFactory を解決します。

ListenerContainerFactoryResolver(BeanFactory) - クラス org.springframework.kafka.retrytopic. ListenerContainerFactoryResolver のコンストラクター

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

コンテナーがアイドル状態になるように構成されている場合に、コンテナーがアイドル状態のときに発生するイベント。

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

提供された引数を使用してインスタンスを構築します。

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

アイドルイベントを発行するように構成されている場合、コンテナーがアイドル状態でなくなったときに発行されるイベント。

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

提供された引数を使用してインスタンスを構築します。

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

コンテナーがアイドル状態になるように構成されている場合に、コンテナーパーティションがアイドル状態になったときに発生するイベント。

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

提供された引数を使用してインスタンスを構築します。

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

アイドルイベントを発行するように構成されている場合、パーティションがアイドルでなくなったときに発行されるイベント。

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

提供された引数を使用してインスタンスを構築します。

ListenerContainerPauseService - org.springframework.kafka.listener のクラス

MessageListenerContainer の一時停止と再開のためのサービス。

ListenerContainerPauseService(ListenerContainerRegistry, TaskScheduler) - クラス org.springframework.kafka.listener. ListenerContainerPauseService のコンストラクター

提供されたレジストリとスケジューラを使用してインスタンスを作成します。

ListenerContainerRegistry - Interface in org.springframework.kafka.listener

リスナーコンテナーのレジストリ。

ListenerExecutionFailedException - Exception in org.springframework.kafka.listener

リスナー固有の KafkaException 拡張。

ListenerExecutionFailedException(String) - Constructor for exception org.springframework.kafka.listener.ListenerExecutionFailedException

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

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

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

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

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

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

Bean 名を介して使用するコンテナーファクトリを構成します。

listenerFactory(ConcurrentKafkaListenerContainerFactory<?, ?>) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder

使用するコンテナーファクトリを構成します。

listenerId - Variable in class org.springframework.kafka.retrytopic.DestinationTopicProcessor.Context

ListenerMetadata - Interface in org.springframework.kafka.listener

KafkaListener に関連付けられたメタデータ。

ListenerType - Enum Class in org.springframework.kafka.listener

リスナーの型を定義します。

ListenerUtils - org.springframework.kafka.listener のクラス

リスナーユーティリティ。

listTopics() - クラス org.springframework.kafka.core.reactive のメソッド。ReactiveKafkaConsumerTemplate

log(Supplier<CharSequence>) - クラス org.springframework.kafka.support のメソッド。LogIfLevelEnabled

log(Supplier<CharSequence>, Throwable) - クラス org.springframework.kafka.support のメソッド。LogIfLevelEnabled

Log4j2LevelAdjuster - org.springframework.kafka.test.rule のクラス

テストメソッドの実行中にクラスのセットのロガーレベルを変更する JUnit メソッド @ ルール。

Log4j2LevelAdjuster(Level, Class<?>...) - クラス org.springframework.kafka.test.rule のコンストラクター。Log4j2LevelAdjuster

logger - Variable in class org.springframework.kafka.config.AbstractKafkaListenerContainerFactory

logger - Variable in class org.springframework.kafka.config.KafkaListenerEndpointRegistry

logger - Variable in class org.springframework.kafka.core.KafkaTemplate

logger - Variable in class org.springframework.kafka.listener.AbstractMessageListenerContainer

logger - Variable in class org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter

logger - Variable in class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter

logger - Variable in class org.springframework.kafka.listener.DeadLetterPublishingRecoverer

logger - Variable in class org.springframework.kafka.listener.FailedRecordProcessor

logger - Variable in class org.springframework.kafka.support.AbstractKafkaHeaderMapper

logger - Variable in class org.springframework.kafka.support.converter.BatchMessagingMessageConverter

logger - Variable in class org.springframework.kafka.support.converter.MessagingMessageConverter

logger - Variable in class org.springframework.kafka.support.LoggingProducerListener

logger() - インターフェース org.springframework.kafka.listener のメソッド。CommonErrorHandler

共通のエラーハンドラーロガー。

LoggingCommitCallback - org.springframework.kafka.listener のクラス

成功した場合は DEBUG レベルで、失敗した場合は ERROR のコミット結果をログに記録します。

LoggingCommitCallback() - クラス org.springframework.kafka.listener. LoggingCommitCallback のコンストラクター

LoggingProducerListener< K , V > - Class in org.springframework.kafka.support

メッセージの送信時にスローされた例外をログに記録する ProducerListener。

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

LogIfLevelEnabled - org.springframework.kafka.support のクラス

構成可能なログレベルをサポートする commons-logging Log のラッパー。

LogIfLevelEnabled(LogAccessor, LogIfLevelEnabled.Level) - クラス org.springframework.kafka.support. LogIfLevelEnabled のコンストラクター

LogIfLevelEnabled.Level - org.springframework.kafka.support の Enum クラス

ログレベル。

logLateArrival(ConsumerRecord<K, R>, Object) - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

LogLevels - Annotation Interface in org.springframework.kafka.test.condition

これでアノテーションが付けられたテストクラスは、テスト間でログレベルを変更します。

LogLevelsCondition - org.springframework.kafka.test.condition のクラス

各テストの前後にログレベルを調整および元に戻す JUnit 条件。

LogLevelsCondition() - クラス org.springframework.kafka.test.condition. LogLevelsCondition のコンストラクター

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