新着情報

このバージョンには 3.7.0 kafka-clients が必要です。Kafka クライアントの 3.7.0 バージョンでは、新しいコンシューマーグループプロトコルが導入されています。詳細と制限については、KIP-848 [Apache] (英語) を参照してください。新しいコンシューマーグループプロトコルは早期アクセスリリースであり、本番環境での使用を意図したものではありません。このバージョンでは、テスト目的でのみ使用することをお勧めします。Spring for Apache Kafka は、kafka-client 自体で利用可能なテストレベルのサポートの範囲内でのみ、この新しいコンシューマーグループプロトコルをサポートします。デフォルトでは、Spring for Apache Kafka は従来のコンシューマーグループプロトコルを使用し、新しいコンシューマーグループプロトコルをテストする場合は、コンシューマーの group.protocol プロパティを介してオプトインする必要があります。

kraft モードは、デフォルトでは EmbeddedKafka では無効になっており、kraft モードを使用するユーザーは有効にする必要があります。これは、EmbeddedKafka を kraft モードで使用する場合、特に新しいコンシューマーグループプロトコルをテストする場合に、特定の不安定性が見られるためです。新しいコンシューマーグループプロトコルは kraft モードでのみサポートされており、このため、新しいプロトコルをテストする場合は、実際の Kafka クラスターに対して行う必要があり、EmbeddedKafka のベースである KafkaClusterTestKit に基づくクラスターに対して行う必要はありません。さらに、kraft モードで複数の KafkaListener メソッドを EmbeddedKafka とともに実行しているときに、他の競合状態もいくつか見られました。これらの課題が解決されるまで、EmbeddedKafka の kraft のデフォルトは false のままになります。

Kafka Streams 対話型クエリで使用されるクエリ可能なストアにアクセスするための新しい API KafkaStreamsInteractiveQuerySupport。詳細については、Kafka ストリームの対話型サポートを参照してください。

transactional.id サフィックスを管理するために、新しい TransactionIdSuffixStrategy インターフェースが導入されました。maxCache をゼロより大きく設定すると、特定の範囲内で transactional.id を再利用できる場合、デフォルトの実装は DefaultTransactionIdSuffixStrategy です。それ以外の場合は、カウンターをインクリメントすることによってサフィックスがオンザフライで生成されます。詳細については、"固定 TransactionIdSuffix" を参照してください。

@KafkaListener (および @KafkaHandler) メソッドは、CompletableFuture<?>、Mono<?>、Kotlin suspend 関数などの非同期戻り値の型を返すことができるようになりました。詳細については、"非同期の戻り値" を参照してください。

メッセージ処理中にスローされた例外の型に基づいて、メッセージをカスタム DLT にリダイレクトできるようになりました。リダイレクトのルールは、RetryableTopic.exceptionBasedDltRouting または RetryTopicConfigurationBuilder.dltRoutingRules を介して設定されます。カスタム DLT は、他の再試行トピックや配信不能トピックと同様に自動的に作成されます。詳細については、"スローされた例外に基づいたカスタム DLT へのメッセージのルーティング" を参照してください。

ContainerProperties の transactionManager プロパティを非推奨にし、代わりに、一般的な PlatformTransactionManager に比べて狭い型である KafkaAwareTransactionManager を使用します。ContainerProperties およびトランザクションの同期を参照してください。

新しい AfterRollbackProcessor API processBatch が提供されます。詳細については、"ロールバック後のプロセッサー" を参照してください。

@RetryableTopic プロパティ SameIntervalTopicReuseStrategy のデフォルト値を SINGLE_TOPIC に変更します。maxInterval 指数遅延の単一トピックを参照してください。

ノンブロッキング再試行は @KafkaListener のクラスをサポートします。ノンブロッキング再試行を参照してください。

RetryTopicConfiguration を見つけるための新しいパブリック API を提供します。RetryTopicConfiguration を探すを参照してください

RetryTopicConfigurer はプロセスをサポートし、MultiMethodKafkaListenerEndpoint を登録します。MultiMethodKafkaListenerEndpoint は、プロパティ defaultMethod および methods に getter/setter を提供します。MethodKafkaListenerEndpoint 型専用の EndpointCustomizer を変更します。EndpointHandlerMethod は、提供された Bean のインスタンスを構築する新しいコンストラクターを追加します。エンドポイントを再試行するためのマルチメソッドをハンドラーに処理する新しいクラス EndpointHandlerMultiMethod を提供します。

ConsumerCallback は、コンシューマー内の現在のオフセットを引数として受け取るユーザー定義関数に基づいてオフセットをシークするための新しい API を提供します。詳細については、API ドキュメントを探すを参照してください。

TopicPartitionOffset.SeekPosition の @PartitionOffset サポートに seekPosition プロパティを追加します。詳細については、手動割り当てを参照してください。

TopicPartitionOffset には、ユーザー提供の関数を受け取り、シークするオフセットを計算する新しいコンストラクターがあります。このコンストラクターを使用すると、フレームワークは、現在のコンシューマーオフセット位置の入力引数を使用して関数を呼び出します。詳細については、API ドキュメントを探すを参照してください。

アプリケーション名を定義する Spring Boot アプリケーションの場合、この名前は、特定のクライアント型に対して自動生成されるクライアント ID のデフォルトのプレフィックスとして使用されるようになりました。詳細については、デフォルトのクライアント ID プレフィックスを参照してください。