Dapr无CloudEvent流式订阅：Java SDK元数据传递问题咨询

针对流式订阅场景下Java SDK无法传递isRawPayload元数据的问题，可通过以下几种方式解决：

1. 扩展Subscription对象手动注入元数据 #

Dapr Java SDK的Subscription类允许修改元数据Map，你可以在构建流式订阅时直接添加该配置：

import io.dapr.client.domain.Subscription;
import java.util.HashMap;
import java.util.Map;

// 构建基础订阅对象
Subscription subscription = Subscription.builder()
    .pubsubName("your-pubsub-component")
    .topic("target-topic")
    .route("/message-handler")
    .build();

// 注入isRawPayload元数据
Map<String, String> metadata = new HashMap<>(subscription.getMetadata());
metadata.put("isRawPayload", "true");
subscription.setMetadata(metadata);

// 注册流式订阅并处理消息
daprClient.subscribe(subscription, (message) -> {
    byte[] rawBytes = message.getRawPayload();
    // 处理原始负载逻辑
    return Mono.empty();
}).block();

2. 直接调用底层gRPC/HTTP API注册订阅 #

如果上层SDK封装存在限制，可绕过SDK直接调用Dapr的底层API完成订阅注册，确保元数据被正确传递：

gRPC方式示例 #

import io.dapr.v1.DaprProtos;
import io.grpc.ManagedChannel;
import io.grpc.ManagedChannelBuilder;

// 建立gRPC连接
ManagedChannel channel = ManagedChannelBuilder.forAddress("localhost", 50051)
    .usePlaintext()
    .build();

DaprProtos.DaprBlockingStub daprStub = DaprProtos.newBlockingStub(channel);

// 构造包含元数据的订阅请求
DaprProtos.SubscribeRequest request = DaprProtos.SubscribeRequest.newBuilder()
    .setPubsubName("your-pubsub-component")
    .setTopic("target-topic")
    .setRoute("/message-handler")
    .putMetadata("isRawPayload", "true")
    .build();

// 启动流式订阅
daprStub.subscribe(request);

3. 临时Workaround：端点直接接收原始负载 #

如果前两种方式无法生效，可直接在消息处理端点接收原始字节数组，绕过SDK的自动解析逻辑：

@PostMapping("/message-handler")
public Mono<Void> handleRawMessage(@RequestBody byte[] rawPayload) {
    // 直接处理原始字节形式的负载
    return Mono.empty();
}

注意：使用此方法时需要确保Dapr向端点传递的是原始负载，需配合订阅元数据的正确配置（可通过声明式订阅文件先配置isRawPayload: true）。

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