Cosmos SDK Java 4.52.0如何从新ChangeFeedProcessor获取RequestCharge？

在4.52.0版本里，若要获取ChangeFeed请求的RU消耗（RequestCharge），不能直接使用接收List<ChangeFeedProcessorItem>的handleChanges方法，需要改用带响应元数据的订阅方式：

• 使用ChangeFeedProcessorBuilder的handleChangesWithResponse方法，该方法接收Consumer<ChangeFeedProcessorResponse>作为参数，ChangeFeedProcessorResponse包含了Feed请求的完整元数据，包括RequestCharge。
• 从ChangeFeedProcessorResponse中，通过getFeedResponse().getRequestCharge()获取RU消耗，同时通过getItems()拿到变更的条目列表。

代码示例 #

ChangeFeedProcessor changeFeedProcessor = new ChangeFeedProcessorBuilder()
    .hostName("your-host-name")
    .container(yourContainer)
    .leaseContainer(yourLeaseContainer)
    .handleChangesWithResponse(response -> {
        // 获取RequestCharge（RU消耗）
        double requestCharge = response.getFeedResponse().getRequestCharge();
        System.out.println("本次请求RU消耗：" + requestCharge);
        
        // 获取变更条目列表
        List<ChangeFeedProcessorItem> items = response.getItems();
        // 处理条目逻辑
        items.forEach(item -> {
            // 处理每个变更项
        });
    })
    .build();

// 启动处理器
changeFeedProcessor.start().block();

内容的提问来源于stack exchange，提问作者JugisPOM