オフセットとパーティション - Kafkaシンクプロセッサ

Question

カフカトポロジを使用して、カフカトピックにレコードを転送しています。

別のプロデューサを使用してメッセージを以前に公開していたため、メッセージのオフセットとパーティションを取得できました。これをContext.forwardに置き換えます。

どのように我々はオフセットを取得し、context.forward

Answer 1

を使用してカフカシンクプロセッサによって送信されたレコードのパーティションがproducer.type=syncモードのトピックにメッセージを公開することができます。 send()メソッドを呼び出すと、探しているすべての詳細が返されます。