インデックス

I

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

このリスナーのコンテナーの一意の識別子。

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

groupId が提供されていない場合は、コンシューマーの group.id プロパティとして id（提供されている場合）を使用します。

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

型情報ヘッダーを無視し、構成されたターゲットクラスを使用します。

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

型情報ヘッダーを無視し、構成されたターゲットクラスを使用します。

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

再試行する必要のある例外型。

includeHeader(DeadLetterPublishingRecoverer.HeaderNames.HeadersToAdd...) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer

ヘッダー名のヘッダー包含ビットを設定します。

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

再試行する必要のある例外クラス名。

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

ターゲット構成を使用するトピック名を構成します。

includeTopics(List<String>) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder

ターゲット構成を使用するトピック名を構成します。

INFERRED - Enum constant in enum class org.springframework.kafka.support.mapping.Jackson2JavaTypeMapper.TypePrecedence

型は、宛先メソッドから推測されます。

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

キー KafkaHeaders.LISTENER_INFO のヘッダーとして追加される静的情報。

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

情報。

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

情報。

initArgumentResolvers() - クラス org.springframework.kafka.listener.adapter のメソッド。KafkaMessageHandlerMethodFactory

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

このメソッドを呼び出して、トピックをチェック / 追加します。これは、アプリケーションコンテキストが初期化されたときにブローカーが使用できず、fatalIfBrokerNotAvailable が false であるか、autoCreate が false に設定されている場合に必要になることがあります。

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

initializeContainer(C, KafkaListenerEndpoint) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerContainerFactory

さらに、指定されたコンテナーを初期化します。

initializeContainer(ConcurrentMessageListenerContainer<K, V>, KafkaListenerEndpoint) - クラス org.springframework.kafka.config のメソッド。ConcurrentKafkaListenerContainerFactory

initialOffset() - Element in annotation interface org.springframework.kafka.annotation.PartitionOffset

PartitionOffset.partition() の初期オフセット。

initialRecordHeaders(Message<?>) - クラス org.springframework.kafka.support.converter のメソッド。JsonMessageConverter

initialRecordHeaders(Message<?>) - クラス org.springframework.kafka.support.converter のメソッド。MessagingMessageConverter

サブクラスは、マップされる前に追加のヘッダーを設定できます。

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

INSTANCE - Static variable in class org.springframework.kafka.support.JavaUtils

このユーティリティクラスのシングルトンインスタンス。

INSTANCE - Static variable in class org.springframework.kafka.support.KafkaNull

KafkaNull のインスタンス。

INSTANCE - Static variable in class org.springframework.kafka.support.micrometer.KafkaListenerObservation.DefaultKafkaListenerObservationConvention

規則のシングルトンインスタンス。

INSTANCE - Static variable in class org.springframework.kafka.support.micrometer.KafkaTemplateObservation.DefaultKafkaTemplateObservationConvention

規則のシングルトンインスタンス。

instantiateAndConfigure(Map<String, ?>, boolean, Map<String, Deserializer<?>>, String, Class<?>) - Static method in class org.springframework.kafka.support.serializer.DelegatingDeserializer

instantiateAndConfigure(Map<String, ?>, boolean, Map<String, Serializer<?>>, String, Class<?>) - Static method in class org.springframework.kafka.support.serializer.DelegatingSerializer

instantiateAndConfigure(Map<String, ?>, boolean, Map<Pattern, T>, Pattern, Class<?>) - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingByTopicSerialization

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

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

レコードに対して何らかのアクションを実行するか、別のアクションを返します。

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

レコードに対して何らかのアクションを実行するか、別のアクションを返します。

intercept(ConsumerRecords<K, V>, Consumer<K, V>) - クラス org.springframework.kafka.listener のメソッド。CompositeBatchInterceptor

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

トピックの再試行プロセスですべての時間関連操作に使用される ClockSE インスタンスを返します。

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

テンプレートが呼び出しスレッドのトランザクションで現在実行されている場合は true を返します。

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

テンプレートが呼び出しスレッドのトランザクションで現在実行されている場合は true を返します。

InvocationResult - Record Class in org.springframework.kafka.listener.adapter

メソッド呼び出しの結果。

InvocationResult(Object, Expression, boolean) - Constructor for record class org.springframework.kafka.listener.adapter.InvocationResult

InvocationResult レコードクラスのインスタンスを作成します。

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

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

各メッセージを処理します。

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

指定されたメッセージでメソッドを呼び出します。

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

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

ハンドラーを呼び出し、専用のエラーメッセージで ListenerExecutionFailedException への例外をラップします。

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

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

処理されたエラーに対してオフセットをコミットする必要がある場合は true を返します（例外はスローされません）。

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

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

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

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

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

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

addTypeInfo プロパティを取得します。

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

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

このテンプレートがトランザクションの場合、トランザクション以外の操作を許可する場合は true を返します。

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

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

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

DelegatingByTypeSerializer.findDelegate(Object, Map) が完全一致ではなく、キーへの割り当て可能性を考慮する必要がある場合は、true を返します。

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

true の場合、非同期手動確認応答がサポートされます。

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

HandlerAdapter の戻り値の型が非同期の場合は true を返します。

isAsyncReplies() - クラス org.springframework.kafka.listener.adapter のメソッド。DelegatingInvocableHandler

いずれかのハンドラーメソッドに非同期応答型がある場合は true を返します。

isAsyncReplies() - クラス org.springframework.kafka.listener.adapter のメソッド。HandlerAdapter

いずれかのハンドラーメソッドに非同期応答型がある場合は true を返します。

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

isAsyncReply(Class<?>) - Static method in class org.springframework.kafka.listener.adapter.AdapterUtils

戻り値の型が非同期の場合は true を返します。

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

このファクトリによって作成されたコンシューマーが自動コミットを使用する場合は true を返します。

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

isAutoCommit() - クラス org.springframework.kafka.mock のメソッド。MockConsumerFactory

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

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

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

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

isBackoffException(Exception) - Static method in class org.springframework.kafka.listener.SeekUtils

例外が KafkaBackoffException の場合、true を返します。

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

このエンドポイントがバッチリスナーを作成する場合は true を返します。

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

このエンドポイントがバッチリスナーを作成する場合は true を返します。

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

true の場合、ロールバック後にバッチレコードを回復します。

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

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

初期化中にコンテナーがコンシューマースレッド名を変更する必要がある場合は、true を返します。

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

null キーを使用した逆直列化例外ヘッダーを常に確認してください。

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

null 値の逆直列化例外ヘッダーを常に確認してください。

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

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

このコンテナーに子コンテナーがある場合、少なくとも 1 つの子が実行されていれば true を返します。

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

回復されたレコードのオフセットをコミットする必要があるかどうか。

isCompletableFuture(Class<?>) - Static method in class org.springframework.kafka.listener.adapter.AdapterUtils

型が CompletableFuture の場合は true を返します。

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

true（デフォルト）の場合、プログラムで提供されるシリアライザー（コンストラクターまたは setter を介して）は、プロデューサー構成を使用して構成されます。

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

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

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

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

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

MessageListenerContainer.pause() が呼び出された場合は true を返します。そして、このコンテナー内のすべてのコンシューマーは実際に一時停止しています。

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

アプリケーションコンテキストがリフレッシュされた場合は true を返します。

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

isDefault() - Element in annotation interface org.springframework.kafka.annotation.KafkaHandler

true の場合、ペイロード型が他の KafkaHandler メソッドと一致しない場合、これがデフォルトのフォールバックメソッドであることを指定します。

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

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

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

isEmptyPayload(Object) - クラス org.springframework.kafka.listener.adapter のメソッド。KafkaNullAwarePayloadArgumentResolver

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

isExistingTransaction(Object) - クラス org.springframework.kafka.transaction のメソッド。KafkaTransactionManager

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

true の場合、送信結果を待ち、失敗した場合は例外をスローします。

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

最終的なトランザクションオフセットを修正するかどうか。

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

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

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

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

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

コンテナーが実行中の場合、開始されたことがない場合、停止された場合は true を返します。

isInstance(Object) - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingByTopicDeserializer

isInstance(Object) - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingByTopicSerialization

このオブジェクトが T のインスタンスである場合、true を返します。

isInstance(Object) - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingByTopicSerializer

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

isJackson2Present() - Static method in class org.springframework.kafka.support.JacksonPresent

isKey() - Method in exception org.springframework.kafka.support.serializer.DeserializationException

キーの逆直列化が失敗した場合は True、それ以外の場合は値の逆直列化が失敗しました。

isKotlinContinuation(Class<?>) - Static method in class org.springframework.kafka.listener.adapter.AdapterUtils

型が Continuation の場合は true を返します。

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

true（INFO）の場合、コンテナー構成をログに記録します。

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

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

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

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

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

true の場合、構成されたトピックのいずれかがブローカーに存在しないと、コンテナーは開始されません。

isMono(Class<?>) - Static method in class org.springframework.kafka.listener.adapter.AdapterUtils

型が Mono の場合は true を返します。

isNegated() - インターフェース org.springframework.kafka.support のメソッド。AbstractKafkaHeaderMapper.HeaderMatcher

このマッチャーがネガティブマッチャーの場合は true を返します。

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

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

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

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

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

isPartitionPaused(TopicPartition) - クラス org.springframework.kafka.listener のメソッド。ConcurrentMessageListenerContainer

isPartitionPaused(TopicPartition) - クラス org.springframework.kafka.listener のメソッド。KafkaMessageListenerContainer

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

このトピックのパーティションが現在一時停止されているかどうか。

isPartitionPauseRequested(TopicPartition) - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer

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

このトピックのパーティションの一時停止がリクエストされているかどうか。

isPaused() - クラス org.springframework.kafka.event のメソッド。ListenerContainerIdleEvent

アイドルイベントが公開されたときにコンシューマーが一時停止された場合は true を返します。

isPaused() - クラス org.springframework.kafka.event のメソッド。ListenerContainerPartitionIdleEvent

アイドルイベントが公開されたときにコンシューマーが一時停止された場合は true を返します。

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

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

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

レコードリスナーでコンテナーを一時停止する場合、一時停止がすぐに有効になるか、現在のレコードが処理されたとき、前のポーリングのすべてのレコードが処理された後に有効になるか。

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

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

MessageListenerContainer.pause() が呼び出された場合は true を返します。コンテナーは実際にはまだ一時停止していない可能性があります。

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

この相関 ID がまだアクティブな場合は true を返します。

isPrimary() - Method in class org.springframework.kafka.core.ABSwitchCluster

プライマリクラスターがアクティブかどうかを取得します。

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

新しいトランザクションで AfterRollbackProcessor.process(List, Consumer, MessageListenerContainer, Exception, boolean, ContainerProperties.EOSMode) を呼び出すには、true を返します。

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

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

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

スレッドごとにプロデューサーが存在する場合は true を返します。

isRelativeToCurrent() - クラス org.springframework.kafka.support のメソッド。TopicPartitionOffset

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

認証例外が原因でコンテナーが停止した場合は、コンテナーを再起動します。

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

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

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

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

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

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

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

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

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

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

例外処理後にシークするかどうかを返します。

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

isSplitIterables() - インターフェース org.springframework.kafka.config のメソッド。KafkaListenerEndpoint

true の場合、IterableSE の戻り結果は個別のレコードに分割されます。

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

true の場合、IterableSE の戻り結果は個別のレコードに分割されます。

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

true の場合、コンテナーは ProducerFencedException の後に停止します。

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

true の場合、コンテナーは現在のレコードを処理した直後に停止します。

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

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

バッチをパーティションごとに分割するかどうかを返します。

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

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

実装がトランザクションをサポートしている (トランザクション対応のプロデューサーファクトリがある) 場合は true を返します。

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

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

公開をトランザクションで実行する必要がある場合は True。