ストリームDSLを使用したKafkaストリームのストリーム/テーブルタイムスタンプ抽出器ごとの指定

Question

私はKafkaストリームを使用して2つの異なるトピックに参加したいと思います。 2つのトピックには異なるフォーマットのデータがあるので、異なるタイムスタンプ抽出プログラムを使用したいと思います。私は、この機能（KAFKA-4144）のための結合されたpullrequestがあったが、プロセッサAPIのために私はonly find itを見た。

この機能はStream API用に存在しますか？

Answer 1

StreamsBuilder#stream(...)には、Consumedというパラメータを取るオーバーロードがあります。これにより、timestamp extractorなどのすべてのオプションのプロパティを指定できます。一般的に

https://docs.confluent.io/current/streams/javadocs/org/apache/kafka/streams/Consumed.html

、あなたはAPIの変更を見つけることができますアップグレードガイドで説明します

• https://docs.confluent.io/current/streams/upgrade-guide.html#api-changes
• https://kafka.apache.org/10/documentation/streams/upgrade-guide#streams_api_changes_100