저는 php-rdkafka 라이브러리를 사용하여 API 프로젝트용 Kafka 소비자를 작성하고 있습니다. 주제의 마지막 오프셋을 찾고 추가 처리를 위해 그 오프셋에서 값을 가져와야 합니다. 예를 들어 주제 = 5의 마지막 오프셋인 경우 오프셋 5를 가져와 새 오프셋이 추가될 때까지 API를 통해 보내야 합니다. 내가 실행하려는 것:

그러나 이는 음수 오프셋이 포함된 이상한 결과를 반환합니다

실제로 마지막 오프셋은 현재 59입니다. 내 생각은 마지막 오프셋을 얻은 다음 다음을 사용하여 값을 얻는 것입니다.

또한 스크립트 작업을 빠르게 수행하기 위해 while(true) 루프를 사용하고 싶지 않습니다.

그게 다예요. 감사해요.