検索

ホームページ  >  に質問  >  本文

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

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

リーリー

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

リーリー

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

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

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

P粉763662390P粉763662390430日前576

全員に返信(1)返信します

  • P粉701491897

    P粉7014918972023-09-11 00:14:41

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

    リーリー

    返事
    0
  • キャンセル返事