1

这个问题询问如何将事件标头数据放入函数中,并且接受的答案说有一种方法。

另一边怎么样 - 是否可以输出带有标题数据的事件?在文档中,我只找到了如何在 C# 中执行此操作。

4

1 回答 1

1

我不知道如何使用输出绑定来做到这一点;据我所知,那些只支持原生 Java 类型或 POJO。 参考

但是,可以直接在 Function 的主体中使用 Java SDK,这将使您能够直接控制形成EventData要发布的实例 - 包括Properties集合和其他元数据。

关于复制数据,如果您希望确保您有一个精确的副本(除了代理拥有的元数据) - 您将希望发布到您已读取的确切分区。 (见下面的示例)

确保分区键可以通过几种不同的方式完成,具体取决于事件中心副本的配置。对于简单的方法,仅使用分区键发布应确保事件最终在副本上的同一分区中 - 假设分区数完全匹配。 (见下面的示例)

Message Annotations如果您的副本具有不同数量的分区,您需要直接发布到分区并操作底层 AMQP 消息以手动将分区键注入该部分,方法是添加具有x-opt-partition-key您的分区键的键和值的项目'希望它反映。为此,您需要使用EventData.getRawAmqpMessage方法。

了解更多信息:

于 2021-10-04T14:00:20.923 回答