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

リーリー

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

リーリー

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

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

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