5

Kafka Streams で PoC を開発しています。次に、ストリーム コンシューマーでオフセット値を取得し、それを使用して(topic-offset)->hash各メッセージの一意のキーを生成する必要があります。その理由は、プロデューサーが syslog であり、ID を持つプロデューサーはごくわずかだからです。再処理の場合は同じキーを再生成する必要があるため、コンシューマーで UUID を生成できません。

私の問題:org.apache.kafka.streams.processor.ProcessorContextクラス.offset()は値を返すメソッドを公開していますが、プロセッサの代わりに KStream を使用しており、同じものを返すメソッドが見つかりませんでした。

KStream から各行の消費者の値を抽出する方法を知っている人はいますか? 前もって感謝します。

4

1 に答える 1

6

process(...)、transform(...)、およびを介して、DSL とプロセッサ API を組み合わせて使用​​できますtransformValues(...)。

プレーンなプロセッサ API と同様に、現在のレコード オフセットにアクセスできます。あなたの場合、 を使いたいようですKStream#transform(...)。

于 2016-11-28T06:03:31.180 に答える