EventHostProcessor의 구현이 주어지면 동일한 프로세서 내에서 마지막 체크 포인트의 이벤트를 강제로 재생할 수 있습니까?EventHostProcessor의 마지막 체크 포인트에서 소비를 다시 시작하십시오.
분명히하려면 내 파티션이 100 인치이고 10 개의 메시지를 소비했다고 가정합니다. 이 재생 방법을 호출하면 에서 이전에 소비 한 10 개의 첫 번째 메시지를 반환 할 수 있습니다.
C#에서는 Stopwatch을 사용할 수 있지만 자바가 표시되지 않습니다.
솔루션은 마지막으로 소비 한 EventData의 최고 수위 점에 체크 포인트를 지정하거나 다른 EventData 인스턴스에 대해 체크 포인트를 지정할 수있는 것으로 보입니다.
이러한 context.checkpoint(data);
로 임의로 EventProcessorHost 내에서 이전 이벤트에 되감기 할 수있는 방법이있을 것 같지 않습니다.
간단한 방법은 튜토리얼 Receive events from Azure Event Hubs using the .NET Framework에서 C# 코드를 Apache Commons Lang 라이브러리의 자바 StopWatch 클래스를 사용하고 다음은 (GitHub의 here, EventProcessorHosthere에 대한 받는다는 의존성에) azure-event-hubs-java 라이브러리와 함께 자바에서 동일한 기능의 코드를 작성하는 것입니다.
희망이 있습니다.
나는 그렇게 생각하지 않는다. 참조하는 스톱워치는 참조 코드의 스톱워치와 다릅니다. 참조 코드는 EH 체크 포인트 스톱워치를 사용합니다. – bearrito
혼란이 있습니다. 나는 그 전화를 타이밍에 정말로 관심이 없다. 체크 포인트 포인터를 이전 시점으로 재설정하는 데 관심이 있습니다. 특히 마지막 검사 점. – bearrito