インデックス

A

abortTransaction() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory.CloseSafeProducer

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

リスナーの ConsumerSeekAware.ConsumerSeekCallback を管理します。

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

AbstractDelegatingMessageListenerAdapter< T > - Class in org.springframework.kafka.listener.adapter

すべてのリスナーアダプターの最上位クラス。

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

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

RecordFilterStrategy を介してレコードフィルターロジックを実装する抽象メッセージリスナーアダプター。

AbstractFilteringMessageListener(T, RecordFilterStrategy<K, V>) - クラス org.springframework.kafka.listener.adapter. AbstractFilteringMessageListener のコンストラクター

AbstractJavaTypeMapper - org.springframework.kafka.support.mapping のクラス

抽象型マッパー。

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

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

KafkaBackOffManagerFactory 実装の基本クラス。

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

ApplicationContext から ListenerContainerRegistry を取得するインスタンスを作成します。

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

提供された ListenerContainerRegistry を使用してインスタンスを作成します。これは、MessageListenerContainer をフェッチしてバックオフするために使用されます。

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

Kafka ヘッダーマッパーのベース。

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

提供されたパターン (送信) とすべてのヘッダー (受信) に一致するマッパーを構築します。

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

提供されたパターン (送信) とすべてのヘッダー (受信) に一致するマッパーを構築します。

AbstractKafkaHeaderMapper.HeaderMatcher - org.springframework.kafka.support のインターフェース

ヘッダーのマッチャー。

AbstractKafkaHeaderMapper.NeverMatchHeaderMatcher - org.springframework.kafka.support のクラス

ヘッダーのセットに一致しないマッチャー。

AbstractKafkaHeaderMapper.SimplePatternBasedHeaderMatcher - org.springframework.kafka.support のクラス

指定されたヘッダーが指定された単純なパターンに一致する場合に一致するパターンベースのヘッダーマッチャー。

AbstractKafkaListenerContainerFactory< C extends AbstractMessageListenerContainer< K , V >, K , V > - Class in org.springframework.kafka.config

Spring の基本コンテナー実装用の基本 KafkaListenerContainerFactory。

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

AbstractKafkaListenerEndpoint< K , V > - Class in org.springframework.kafka.config

Kafka リスナーエンドポイントの基本モデル。

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

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

MessageListenerContainer の基本実装。

AbstractMessageListenerContainer(ConsumerFactory<? super K, ? super V>, ContainerProperties) - クラス org.springframework.kafka.listener. AbstractMessageListenerContainer のコンストラクター

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

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

メッセージリスナーアダプターを再試行するための基本クラス。

AbstractRetryingMessageListenerAdapter(T, RetryTemplate) - クラス org.springframework.kafka.listener.adapter. AbstractRetryingMessageListenerAdapter のコンストラクター

提供された再試行テンプレートを使用してインスタンスを構築します。

AbstractRetryingMessageListenerAdapter(T, RetryTemplate, RecoveryCallback<? extends Object>) - クラス org.springframework.kafka.listener.adapter. AbstractRetryingMessageListenerAdapter のコンストラクター

提供されたテンプレートとコールバックを使用してインスタンスを構築します。

ABSwitchCluster - Class in org.springframework.kafka.core

サーバーの 2 つのリストを切り替えることができるブートストラップサーバーの SupplierSE。

ABSwitchCluster(String, String) - Constructor for class org.springframework.kafka.core.ABSwitchCluster

プライマリおよびセカンダリブートストラップサーバーを使用してインスタンスを構築します。

accept(ConsumerRecord<?, ?>, Exception) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerAwareRecordRecoverer

accept(ConsumerRecord<?, ?>, Consumer<?, ?>, Exception) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerAwareRecordRecoverer

レコードを回復します。

accept(ConsumerRecord<?, ?>, Consumer<?, ?>, Exception) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer

acceptIfCondition(boolean, T1, T2, BiConsumer<T1, T2>) - クラス org.springframework.kafka.support のメソッド。JavaUtils

条件が真の場合は、引数を使用して BiConsumer.accept(Object, Object)SE を呼び出します。

acceptIfCondition(boolean, T, Consumer<T>) - クラス org.springframework.kafka.support のメソッド。JavaUtils

条件が真の場合、値を使用して Consumer.accept(Object)SE を呼び出します。

acceptIfHasText(String, Consumer<String>) - クラス org.springframework.kafka.support のメソッド。JavaUtils

null または空でない場合は、値を使用して Consumer.accept(Object)SE を呼び出します。

acceptIfHasText(T, String, BiConsumer<T, String>) - クラス org.springframework.kafka.support のメソッド。JavaUtils

value 引数が null または空でない場合は、引数を使用して BiConsumer.accept(Object, Object)SE を呼び出します。

acceptIfInstanceOf(Class<T>, Object, Consumer<T>) - クラス org.springframework.kafka.support のメソッド。JavaUtils

オブジェクトが提供されたクラスのインスタンスである場合は、キャスト値を使用して Consumer.accept(Object)SE を呼び出します。

acceptIfNotEmpty(List<T>, Consumer<List<T>>) - クラス org.springframework.kafka.support のメソッド。JavaUtils

null または空でない場合は、値を使用して Consumer.accept(Object)SE を呼び出します。

acceptIfNotEmpty(T[], Consumer<T[]>) - クラス org.springframework.kafka.support のメソッド。JavaUtils

null または空でない場合は、値を使用して Consumer.accept(Object)SE を呼び出します。

acceptIfNotNull(T1, T2, BiConsumer<T1, T2>) - クラス org.springframework.kafka.support のメソッド。JavaUtils

t2 引数が null でない場合は、引数を使用して BiConsumer.accept(Object, Object)SE を呼び出します。

acceptIfNotNull(T, Consumer<T>) - クラス org.springframework.kafka.support のメソッド。JavaUtils

null でない場合は、値を使用して Consumer.accept(Object)SE を呼び出します。

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

確認応答が作成されたレコードまたはバッチが処理されたときに呼び出されます。

acknowledge(int) - Method in interface org.springframework.kafka.support.Acknowledgment

バッチ内のインデックスでレコードを確認します。インデックスを含む、バッチ内のレコードのオフセットをコミットします。

acknowledge(Acknowledgment) - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter

ACKNOWLEDGING - Enum constant in enum class org.springframework.kafka.listener.ListenerType

認めます。

ACKNOWLEDGING_CONSUMER_AWARE - Enum constant in enum class org.springframework.kafka.listener.ListenerType

認知とコンシューマー意識。

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

受信 Kafka メッセージを処理するためのリスナーであり、メッセージが処理されたときに受信者が呼び出すことができる確認ハンドルを伝達します。

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

受信 Kafka メッセージを処理するためのリスナーであり、メッセージが処理されたときに受信者が呼び出すことができる確認ハンドルを伝達します。

Acknowledgment - Interface in org.springframework.kafka.support

ConsumerRecord の処理を承認するためのハンドル。

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

Acknowledgment のヘッダー。

acquireSuffix(String) - クラス org.springframework.kafka.core のメソッド。DefaultTransactionIdSuffixStrategy

トランザクションプロデューサーのサフィックスをキャッシュから取得するか、キャッシュが無効になっている場合は新しいサフィックスを生成します。

acquireSuffix(String) - インターフェース org.springframework.kafka.core のメソッド。TransactionIdSuffixStrategy

トランザクションプロデューサーのサフィックスを取得します。

adapt(List<Message<?>>, List<ConsumerRecord<K, V>>, Acknowledgment, Consumer<?, ?>, BatchToRecordAdapter.Callback<K, V>) - インターフェース org.springframework.kafka.listener.adapter のメソッド。BatchToRecordAdapter

リストを調整し、各メッセージのコールバックを呼び出します。

adapt(List<Message<?>>, List<ConsumerRecord<K, V>>, Acknowledgment, Consumer<?, ?>, BatchToRecordAdapter.Callback<K, V>) - クラス org.springframework.kafka.listener.adapter のメソッド。DefaultBatchToRecordAdapter

AdapterUtils - org.springframework.kafka.listener.adapter のクラス

リスナーアダプターのユーティリティ。

ADD_TYPE_INFO_HEADERS - Static variable in class org.springframework.kafka.support.serializer.JsonSerializer

型ヘッダーの追加を無効にするための Kafka 構成プロパティ。

ADD_TYPE_INFO_HEADERS - Static variable in class org.springframework.kafka.support.serializer.ToStringSerializer

型ヘッダーの追加を有効 / 無効にするための Kafka 構成プロパティ。

addContainers(MessageListenerContainer...) - クラス org.springframework.kafka.listener のメソッド。ContainerGroup

1 つ以上のコンテナーをグループに追加します。

addDelegate(Class<? extends Throwable>, CommonErrorHandler) - クラス org.springframework.kafka.listener のメソッド。CommonDelegatingErrorHandler

現在のコレクションの最後にデリゲートを追加します。

addDelegate(String, Deserializer<?>) - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingDeserializer

addDelegate(String, Serializer<?>) - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingSerializer

addDelegate(Pattern, T) - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingByTopicSerialization

addDelegate(ProducerListener<K, V>) - クラス org.springframework.kafka.support のメソッド。CompositeProducerListener

addDestinationTopics(String, List<DestinationTopic>) - クラス org.springframework.kafka.retrytopic のメソッド。DefaultDestinationTopicResolver

addDestinationTopics(String, List<DestinationTopic>) - インターフェース org.springframework.kafka.retrytopic のメソッド。DestinationTopicContainer

提供された宛先トピックをコンテナーに追加します。

addHeader(Headers, String, Class<?>) - クラス org.springframework.kafka.support.mapping のメソッド。AbstractJavaTypeMapper

addHeadersFunction(BiFunction<ConsumerRecord<?, ?>, Exception, Headers>) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer

公開されたレコードに追加する追加のヘッダーを取得するために呼び出される関数を追加します。

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

返信メッセージに追加する追加のヘッダーのマップ。

addKafkaStreamsCustomizers(List<KafkaStreamsCustomizer>) - クラス org.springframework.kafka.config のメソッド。CompositeKafkaStreamsCustomizer

addKafkaStreamsCustomizers(KafkaStreamsInfrastructureCustomizer...) - クラス org.springframework.kafka.config のメソッド。CompositeKafkaStreamsInfrastructureCustomizer

カスタマイザーを追加します。

addListener(int, ConsumerFactory.Listener<K, V>) - インターフェース org.springframework.kafka.core のメソッド。ConsumerFactory

特定のインデックスにリスナーを追加します。

addListener(int, ConsumerFactory.Listener<K, V>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaConsumerFactory

特定のインデックスにリスナーを追加します。

addListener(int, ProducerFactory.Listener<K, V>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory

特定のインデックスにリスナーを追加します。

addListener(int, ProducerFactory.Listener<K, V>) - インターフェース org.springframework.kafka.core のメソッド。ProducerFactory

特定のインデックスにリスナーを追加します。

addListener(StreamsBuilderFactoryBean.Listener) - クラス org.springframework.kafka.config のメソッド。StreamsBuilderFactoryBean

ストリームの開始と停止の後に呼び出される StreamsBuilderFactoryBean.Listener を追加します。

addListener(ConsumerFactory.Listener<K, V>) - インターフェース org.springframework.kafka.core のメソッド。ConsumerFactory

リスナーを追加します。

addListener(ConsumerFactory.Listener<K, V>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaConsumerFactory

リスナーを追加します。

addListener(ProducerFactory.Listener<K, V>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory

リスナーを追加します。

addListener(ProducerFactory.Listener<K, V>) - インターフェース org.springframework.kafka.core のメソッド。ProducerFactory

リスナーを追加します。

addMatchers(AbstractKafkaHeaderMapper.HeaderMatcher...) - クラス org.springframework.kafka.support のメソッド。AbstractKafkaHeaderMapper

サブクラスは、これを呼び出してカスタム AbstractKafkaHeaderMapper.HeaderMatcher を追加できます。

addNotRetryableException(Class<? extends Exception>) - クラス org.springframework.kafka.retrytopic のメソッド。DeadLetterPublishingRecovererFactory

デフォルトリストに例外型を追加します。

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

例外型をデフォルトリストに追加します。

addPostProcessor(ConsumerPostProcessor<K, V>) - インターフェース org.springframework.kafka.core のメソッド。ConsumerFactory

ポストプロセッサーを追加します。

addPostProcessor(ConsumerPostProcessor<K, V>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaConsumerFactory

addPostProcessor(ProducerPostProcessor<K, V>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory

addPostProcessor(ProducerPostProcessor<K, V>) - インターフェース org.springframework.kafka.core のメソッド。ProducerFactory

ポストプロセッサーを追加します。

addRawMappedHeader(String, boolean) - クラス org.springframework.kafka.support のメソッド。AbstractKafkaHeaderMapper

生のマップされたヘッダーを追加します。

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

再試行できる例外型を追加します。

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

MethodKafkaListenerEndpoint の EndpointCustomizer を作成し、MultiMethodKafkaListenerEndpoint をサポートします。

addSuffixesAndMethod(DestinationTopic.Properties, Object, Method) - クラス org.springframework.kafka.retrytopic のメソッド。EndpointCustomizerFactory

非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。

addTopics(String...) - インターフェース org.springframework.kafka.test のメソッド。EmbeddedKafkaBroker

構成された数のパーティションを使用して、既存のブローカーにトピックを追加します。

addTopics(String...) - クラス org.springframework.kafka.test のメソッド。EmbeddedKafkaKraftBroker

構成された数のパーティションを使用して、既存のブローカーにトピックを追加します。

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

構成された数のパーティションを使用して、既存のブローカーにトピックを追加します。

addTopics(NewTopic...) - インターフェース org.springframework.kafka.test のメソッド。EmbeddedKafkaBroker

既存のブローカーにトピックを追加します。

addTopics(NewTopic...) - クラス org.springframework.kafka.test のメソッド。EmbeddedKafkaKraftBroker

既存のブローカーにトピックを追加します。

addTopics(NewTopic...) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker

既存のブローカーにトピックを追加します。

addTopicsWithResults(String...) - インターフェース org.springframework.kafka.test のメソッド。EmbeddedKafkaBroker

構成された数のパーティションを使用して、既存のブローカーにトピックを追加します。

addTopicsWithResults(String...) - クラス org.springframework.kafka.test のメソッド。EmbeddedKafkaKraftBroker

構成された数のパーティションを使用して、既存のブローカーにトピックを追加します。

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

構成された数のパーティションを使用して、既存のブローカーにトピックを追加します。

addTopicsWithResults(NewTopic...) - インターフェース org.springframework.kafka.test のメソッド。EmbeddedKafkaBroker

トピックを既存のブローカーに追加し、結果のマップを返します。

addTopicsWithResults(NewTopic...) - クラス org.springframework.kafka.test のメソッド。EmbeddedKafkaKraftBroker

トピックを既存のブローカーに追加し、結果のマップを返します。

addTopicsWithResults(NewTopic...) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker

トピックを既存のブローカーに追加し、結果のマップを返します。

addToStringClasses(String...) - クラス org.springframework.kafka.support のメソッド。DefaultKafkaHeaderMapper

送信マッパーがマッピングの前に toString() 操作を実行する必要があるクラス名を追加します。

addTrustedPackages(String...) - クラス org.springframework.kafka.support のメソッド。DefaultKafkaHeaderMapper

JSON からオブジェクトを構築するときに使用される信頼できるパッケージのリストにパッケージを追加します。

addTrustedPackages(String...) - クラス org.springframework.kafka.support.mapping のメソッド。DefaultJackson2JavaTypeMapper

逆直列化中に信頼する一連のパッケージを指定します。

addTrustedPackages(String...) - インターフェース org.springframework.kafka.support.mapping のメソッド。Jackson2JavaTypeMapper

addTrustedPackages(String...) - クラス org.springframework.kafka.support.serializer のメソッド。JsonDeserializer

デシリアライズ用の信頼できるパッケージを追加します。

addTypeInfo - Variable in class org.springframework.kafka.support.serializer.JsonSerializer

adjustLogLevels(String, List<Class<?>>, List<String>, Level) - Static method in class org.springframework.kafka.test.utils.JUnitUtils

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

管理操作のタイムアウト（秒単位）（例:

adminTimeout(int) - インターフェース org.springframework.kafka.test のメソッド。EmbeddedKafkaBroker

管理操作のタイムアウトを秒単位で設定します (例:

adminTimeout(int) - クラス org.springframework.kafka.test のメソッド。EmbeddedKafkaKraftBroker

adminTimeout(int) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker

after() - クラス org.springframework.kafka.test.rule のメソッド。EmbeddedKafkaRule

afterAll(ExtensionContext) - クラス org.springframework.kafka.test.condition のメソッド。EmbeddedKafkaCondition

afterAll(ExtensionContext) - クラス org.springframework.kafka.test.condition のメソッド。LogLevelsCondition

afterEach(ExtensionContext) - クラス org.springframework.kafka.test.condition のメソッド。LogLevelsCondition

afterPropertiesSet() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint

afterPropertiesSet() - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistrar

afterPropertiesSet() - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

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

afterPropertiesSet() - インターフェース org.springframework.kafka.test のメソッド。EmbeddedKafkaBroker

afterPropertiesSet() - クラス org.springframework.kafka.test のメソッド。EmbeddedKafkaKraftBroker

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

afterRecord(ConsumerRecord<K, V>, Consumer<K, V>) - クラス org.springframework.kafka.listener のメソッド。CompositeRecordInterceptor

afterRecord(ConsumerRecord<K, V>, Consumer<K, V>) - インターフェース org.springframework.kafka.listener のメソッド。RecordInterceptor

レコードの処理が RecordInterceptor.success(ConsumerRecord, Consumer) または RecordInterceptor.failure(ConsumerRecord, Exception, Consumer) のいずれかで完了したときに呼び出されます。

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

未処理のレコード (失敗したレコードを含む) が残っているリスナーコンテナーによって呼び出されます。

afterSingletonsInstantiated() - クラス org.springframework.kafka.annotation のメソッド。KafkaListenerAnnotationBeanPostProcessor

afterSingletonsInstantiated() - クラス org.springframework.kafka.config のメソッド。StreamsBuilderFactoryBean

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

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

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

afterSingletonsInstantiated() - クラス org.springframework.kafka.security.jaas のメソッド。KafkaJaasLoginModuleInitializer

AGGREGATED_RESULTS_TOPIC - Static variable in class org.springframework.kafka.requestreply.AggregatingReplyingKafkaTemplate

集約された結果を持つ「外部」 ConsumerRecord の疑似トピック名は、リリース戦略による通常のリリース後の値になります。

AggregatingReplyingKafkaTemplate< K , V , R > - Class in org.springframework.kafka.requestreply

同じ相関 ID を持つ複数の応答を集約する応答テンプレート。

AggregatingReplyingKafkaTemplate(ProducerFactory<K, V>, GenericMessageListenerContainer<K, Collection<ConsumerRecord<K, R>>>, BiPredicate<List<ConsumerRecord<K, R>>, Boolean>) - クラス org.springframework.kafka.requestreply. AggregatingReplyingKafkaTemplate のコンストラクター

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

AllowDenyCollectionManager< T > - Class in org.springframework.kafka.support

許可 / 拒否コレクションとその述語を管理するためのクラス。

AllowDenyCollectionManager(Collection<T>, Collection<T>) - クラス org.springframework.kafka.support. AllowDenyCollectionManager のコンストラクター

AllowDenyCollectionManager(Collection<T>, Collection<T>, Collection<Predicate<T>>) - クラス org.springframework.kafka.support. AllowDenyCollectionManager のコンストラクター

allStopped() - クラス org.springframework.kafka.listener のメソッド。ContainerGroup

このグループのすべてのコンテナーが停止している場合は true を返します。

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

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

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

DLT 処理に失敗した場合に備えて、再処理のために常にメッセージを DLT に返送してください。

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

試行ごとにリスナー例外をログに記録します。

apply(Statement, FrameworkMethod, Object) - クラス org.springframework.kafka.test.rule のメソッド。Log4j2LevelAdjuster

areAllowed(T[]) - クラス org.springframework.kafka.support のメソッド。AllowDenyCollectionManager

asProperties() - クラス org.springframework.kafka.config のメソッド。KafkaStreamsConfiguration

構成マップを PropertiesSE として返します。

assertBeanFactory() - クラス org.springframework.kafka.annotation のメソッド。KafkaListenerAnnotationBeanPostProcessor

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

assignReplicas(int, List<Integer>) - クラス org.springframework.kafka.config のメソッド。TopicBuilder

個別のレプリカ割り当てを追加します。

asyncFailure(Object, Acknowledgment, Consumer<?, ?>, Throwable, Message<?>) - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter

AsyncRepliesAware - Interface in org.springframework.kafka.listener.adapter

このインターフェースを実装するメッセージハンドラーアダプターは、HandlerAdapter 非同期戻り値の型を検出できます。

asyncSuccess(Object, String, Message<?>, boolean) - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter

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

メッセージが DLT に送信される前に行われた試行の数。

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

認可例外が発生しました。

AUTHENTICATION - Enum constant in enum class org.springframework.kafka.event.ConsumerRetryAuthEvent.Reason

認証例外が発生しました。

AUTHORIZATION - Enum constant in enum class org.springframework.kafka.event.ConsumerRetryAuthEvent.Reason

認可例外が発生しました。

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

提供された構成で登録した後にトピックを作成する必要があるかどうか。

autoCreateTopics(Boolean, Integer, Short) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder

オプションで、提供されたプロパティを使用してトピックを作成するようにトピック作成動作を構成します。

autoCreateTopicsWith(Integer, Short) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder

指定されたプロパティでトピックを自動作成するようにトピック作成動作を構成します。

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

DLT コンテナーのみのコンテナーファクトリの autoStartup プロパティをオーバーライドします。

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

autoStartDltHandler(Boolean) - クラス org.springframework.kafka.retrytopic のメソッド。DestinationTopicPropertiesFactory

DLT ハンドラーを開始しない場合は、false に設定します。

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

DLT ハンドラー (構成済みまたはデフォルト) を開始しない場合は false に設定し、コンテナーファクトリの autoStartup プロパティをオーバーライドします。

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

コンテナーファクトリのデフォルト設定を上書きするには、true または false に設定します。