如何在 Stream 云功能中设置 Key

Question

我正在使用流云流来接收事件并将其发布到 kafka 我也使用函数式编程模型。

假设我有这个 bean 定义：

@Bean
public Function<InputMsg,OutputMsg> handle(){
//do some calculation that returns OutputMsg
}

如何控制消息的键？那就是我想将 OutputMsg 事件发送回 kafka 但我不知道如何控制键，只有值（在我的示例中为 OutputMsg）

Answer 1

请改用Function<Message<InputMsg>, Message<OutputMsg>>。

入站消息中，key在msg.getHeaders().get(KafkaHeaders.RECEIVED_MESSAGE_KEY)；要在出站消息中设置密钥，请设置KafkaHeaders.MESSAGE_KEY。