ackCount
| 1 | ackMode が COUNT または COUNT_TIME の場合に、保留中のオフセットをコミットする前のレコード数。
|
adviceChain
| null
| メッセージリスナーをラップする Advice オブジェクトのチェーン（アドバイスの周囲の MethodInterceptor など）。順番に呼び出されます。 |
ackMode
| BATCH | オフセットがコミットされる頻度を制御します。オフセットのコミットを参照してください。 |
ackTime
| 5000 | ackMode が TIME または COUNT_TIME の場合に、保留中のオフセットがコミットされるまでのミリ秒単位の時間。
|
assignmentCommitOption
| LATEST_ONLY _NO_TX | 割り当て時に初期位置をコミットするかどうか。デフォルトでは、初期オフセットは ConsumerConfig.AUTO_OFFSET_RESET_CONFIG が latest の場合にのみコミットされ、トランザクションマネージャーが存在する場合でもトランザクション内で実行されません。利用可能なオプションの詳細については、ContainerProperties.AssignmentCommitOption の JavaDocs を参照してください。 |
asyncAcks
| false
| アウトオブオーダーコミットを有効にします ( 手動でオフセットをコミットするを参照)。コンシューマーは一時停止され、ギャップが埋まるまでコミットは延期されます。 |
authExceptionRetryInterval
| null
| null でない場合、AuthenticationException または AuthorizationException が Kafka クライアントによってスローされたときに、ポーリング間でスリープする Duration。null の場合、そのような例外は致命的と見なされ、コンテナーは停止します。 |
batchRecoverAfterRollback
| false
| バッチリカバリを有効にするには、true に設定します。ロールバック後プロセッサーを参照してください。 |
clientId
| （空の文字列） | client.id コンシューマープロパティのプレフィックス。コンシューマーファクトリの client.id プロパティをオーバーライドします。並行コンテナーでは、-n が各コンシューマーインスタンスのサフィックスとして追加されます。
|
checkDeserExWhenKeyNull
| false | null key を受信したときに、常に DeserializationException ヘッダーをチェックするには、true に設定します。委譲デシリアライザーを使用している場合など、コンシューマーコードが ErrorHandlingDeserializer が構成されていることを判別できない場合に役立ちます。
|
checkDeserExWhenValueNull
| false | null value を受信したときに、常に DeserializationException ヘッダーをチェックするには、true に設定します。委譲デシリアライザーを使用している場合など、コンシューマーコードが ErrorHandlingDeserializer が構成されていることを判別できない場合に役立ちます。
|
commitCallback
| null
| 存在し、syncCommits が false の場合、コミットの完了後にコールバックが呼び出されます。 |
commitLogLevel
| DEBUG | オフセットのコミットに関連するログのログレベル。 |
consumerRebalanceListener
| null
| リバランスリスナー。リスナーのリバランスを参照してください。 |
commitRetries
| 3 | true に設定された syncCommits を使用する場合は、リトライ回数 RetriableCommitFailedException を設定します。デフォルトは 3 (合計 4 回の試行)。 |
consumerStartTimeout
| 30 代 | エラーをログに記録する前に、コンシューマーが開始するのを待つ時間。これは、たとえば、スレッドが不十分なタスクエグゼキュータを使用している場合に発生する可能性があります。 |
deliveryAttemptHeader
| false
| 配信試行ヘッダーを参照してください。 |
eosMode
| V2
| 正確に一度のセマンティクスモード。正確に一度セマンティクスを参照してください。 |
fixTxOffsets
| false
| トランザクションプロデューサーによって作成されたレコードを消費するときに、コンシューマーがパーティションの最後に位置する場合、トランザクションのコミット / ロールバックを示すために使用される疑似レコードと、おそらくロールバックされたレコードの存在により、ラグが誤ってゼロより大きく報告されることがあります。これは関数にはコンシューマーに影響を与えませんが、一部のユーザーは「ラグ」がゼロでないことに関心事を示しています。このプロパティを true に設定すると、コンテナーはこのようなオフセットの誤報を修正します。このチェックは、コミット処理が著しく複雑にならないように、次のポーリングの前に実行されます。執筆時点では、コンシューマーが isolation.level=read_committed で構成されており、max.poll.records が 1 より大きい場合にのみラグが修正されます。詳細は KAFKA-10683 [Apache] (英語) を参照してください。 |
groupId
| null
| コンシューマーの group.id プロパティをオーバーライドします。@KafkaListener id または groupId プロパティによって自動的に設定されます。 |
idleBeforeDataMultiplier
| 5.0 | レコードを受信する前に適用される idleEventInterval の乗数。レコードを受信すると、乗数は適用されなくなります。バージョン 2.8 以降で使用できます。 |
idleBetweenPolls
| 0 | ポーリングの間にスレッドをスリープさせることにより、配信を遅くするために使用されます。レコードのバッチとこの値を処理する時間は、max.poll.interval.ms コンシューマープロパティよりも短くする必要があります。 |
idleEventInterval
| null
| 設定すると、ListenerContainerIdleEvent の公開が有効になります。アプリケーションイベントおよびアイドル状態のコンシューマーと無反応なコンシューマーの検出を参照してください。idleBeforeDataMultiplier も参照してください。 |
idlePartitionEventInterval
| null
| 設定すると、ListenerContainerIdlePartitionEvent の公開が有効になります。アプリケーションイベントおよびアイドル状態のコンシューマーと無反応なコンシューマーの検出を参照してください。 |
kafkaConsumerProperties
| なし | コンシューマーファクトリで構成された任意のコンシューマープロパティをオーバーライドするために使用されます。 |
kafkaAwareTransactionManager
| null
| トランザクションを参照してください。 |
listenerTaskExecutor
| SimpleAsyncTaskExecutor
| コンシューマースレッドを実行するタスクエグゼキュータ。デフォルトのエグゼキュータは、<name>-C-n という名前のスレッドを作成します。KafkaMessageListenerContainer の場合、名前は Bean 名です。ConcurrentMessageListenerContainer の場合、名前は -n が付加された Bean 名であり、n は子コンテナーごとに増分されます。 |
logContainerConfig
| false
| すべてのコンテナーのプロパティを INFO レベルでログに記録するには、true に設定します。 |
messageListener
| null
| メッセージリスナー。 |
micrometerEnabled
| true
| コンシューマースレッドの Micrometer タイマーを維持するかどうか。 |
micrometerTags
| 空 | micrometer メトリクスに追加される静的タグのマップ。 |
micrometerTagsProvider
| null
| コンシューマーの記録に基づいて動的タグを提供する機能。 |
missingTopicsFatal
| false
| true の場合、構成されたトピックがブローカー上に存在しない場合、コンテナーは起動されません。 |
monitorInterval
| 30 代 | NonResponsiveConsumerEvent のコンシューマースレッドの状態をチェックする頻度。noPollThreshold および pollTimeout を参照してください。
|
noPollThreshold
| 3.0 | pollTimeOut を掛けて、NonResponsiveConsumerEvent を公開するかどうかを決定します。monitorInterval を参照してください。
|
observationConvention
| null
| 設定すると、コンシューマーレコードの情報に基づいて、動的タグがタイマーとトレースに追加されます。 |
observationEnabled
| false
| true に設定すると、Micrometer 経由での観測が可能になります。
|
offsetAndMetadataProvider
| null
| OffsetAndMetadata のプロバイダー ; デフォルトでは、プロバイダーは空のメタデータを使用してオフセットとメタデータを作成します。プロバイダーは、メタデータをカスタマイズする方法を提供します。
|
onlyLogRecordMetadata
| false
| topic-partition@offset だけでなく、完全なコンシューマーレコード (エラー、デバッグログなど) をログに記録するには、false に設定します。
|
pauseImmediate
| false
| コンテナーが一時停止すると、前のポーリングからのすべてのレコードを処理した後ではなく、現在のレコードの後に処理を停止します。残りのレコードはメモリに保持され、コンテナーが再開されたときにリスナーに渡されます。 |
pollTimeout
| 5000 | ミリ秒単位で Consumer.poll() に渡されたタイムアウト。 |
pollTimeoutWhilePaused
| 100 | コンテナーが一時停止状態のときに Consumer.poll() に渡されるタイムアウト (ミリ秒単位)。 |
restartAfterAuthExceptions
| false | 認可 / 認証の例外が原因でコンテナーが停止した場合にコンテナーを再起動するには、True。 |
scheduler
| ThreadPoolTaskScheduler
| コンシューマーモニタータスクを実行するスケジューラー。 |
shutdownTimeout
| 10000 | すべてのコンシューマーが停止し、コンテナー停止イベントを公開するまでに stop() メソッドをブロックする最大時間（ミリ秒単位）。 |
stopContainerWhenFenced
| false
| ProducerFencedException がスローされた場合は、リスナーコンテナーを停止します。詳細については、ロールバック後のプロセッサーを参照してください。
|
stopImmediate
| false
| コンテナーが停止したら、前のポーリングのすべてのレコードを処理した後ではなく、現在のレコードの後で処理を停止します。 |
subBatchPerPartition
| 説明を参照してください。 | バッチリスナーを使用する場合、これが true の場合、リスナーはポーリングの結果を使用して呼び出され、パーティションごとに 1 つのサブバッチに分割されます。デフォルト false。 |
syncCommitTimeout
| null
| syncCommits が true の場合に使用するタイムアウト。設定されていない場合、コンテナーは default.api.timeout.ms コンシューマープロパティを決定し、それを使用しようとします。それ以外の場合は 60 秒を使用します。
|
syncCommits
| true
| オフセットに同期コミットと非同期コミットのどちらを使用するか。commitCallback を参照してください。 |
topics topicPattern topicPartitions
| なし | 構成されたトピック、トピックパターン、明示的に割り当てられたトピック / パーティション。相互に排他的。少なくとも 1 つ提供する必要があります。ContainerProperties コンストラクターによって実施されます。 |
transactionManager
| null
| 3.2 以降は非推奨になりました。[kafkaAware トランザクションマネージャー ]、他のトランザクションマネージャーを参照してください。 |
