PHPライブラリを使用してKafkaからトピックの最後のオフセットを取得するにはどうすればよいですか?

Question

私は php-rdkafka ライブラリを使用して API プロジェクトの Kafka コンシューマーを作成しています。トピック内の最後のオフセットを見つけて、その後の処理のためにそこから値を取得する必要があります。たとえば、トピックの最後のオフセット = 5 の場合、オフセット 5 を取得し、新しいオフセットが追加されるまで API 経由で送信する必要があります。私が実行しようとしているもの:

リーリー

しかし、これは負のオフセットを持つ奇妙な結果を返します

リーリー

実際には、現在の最後のオフセットは 59 です。私のアイデアは、最後のオフセットを取得してから、次を使用して値を取得することです。 リーリー

また、スクリプト作業を迅速に実行するために while(true) ループを使用したくありません。

＃＃＃それだけです。ありがとう。

Answer 1

答えを見つけました。それは私にとってはうまくいきました:

リーリー