我正在使用 EventProcessorClient 從事件中心讀取事件。如何限制此客戶端從特定磁區讀取?
我像這樣創建它:
EventProcessorClientBuilder eventProcessorClientBuilder = new EventProcessorClientBuilder()
.connectionString(connectionString, eventHubName)
.consumerGroup(EventHubClientBuilder.DEFAULT_CONSUMER_GROUP_NAME)
.processEvent(IncomingEventProcessor.processEvent)
.processError(processError)
.checkpointStore(new BlobCheckpointStore(blobContainerAsyncClient));
EventProcessorClient eventProcessorClient = eventProcessorClientBuilder.buildEventProcessorClient();
將針對事件中心上的所有事件呼叫“processEvent”中的函式參考器 - 對于所有磁區。我可以在該函式中檢查事件與哪個磁區相關,但我希望只接收來自特定磁區的事件。
這可以使用 EventProcessorClient 嗎?
uj5u.com熱心網友回復:
使用 EventProcessorClient 是不可能的,但是您可以使用 EventHubConsumerAsyncClient 類來實作您要查找的內容,請參閱檔案,它包含一個receiveFromPartition方法
uj5u.com熱心網友回復:
我發現這EventProcessorClient是自平衡的 - 即它將在連接到事件中心的實體數量上分配磁區。
轉載請註明出處,本文鏈接:https://www.uj5u.com/houduan/368321.html
標籤:爪哇 天蓝色 azure-eventhub
