Stream云功能中如何设置Key
How to set Key in Stream cloud function
我正在使用流云流来接收事件并将其发布到 kafka
我也是用的函数式编程模型。
假设我有这个 bean 定义：
@Bean
public Function<InputMsg,OutputMsg> handle(){
//do some calculation that returns OutputMsg
}
如何控制消息的密钥？那就是我想将 OutputMsg 事件发送回 kafka 但我不知道如何控制键，只有值（在我的示例中为 OutputMsg）
改用Function<Message<InputMsg>, Message<OutputMsg>>。
入站消息中，key在msg.getHeaders().get(KafkaHeaders.RECEIVED_MESSAGE_KEY)；要在出站消息中设置密钥，请设置 KafkaHeaders.MESSAGE_KEY.
我正在使用流云流来接收事件并将其发布到 kafka 我也是用的函数式编程模型。
假设我有这个 bean 定义：
@Bean
public Function<InputMsg,OutputMsg> handle(){
//do some calculation that returns OutputMsg
}
如何控制消息的密钥？那就是我想将 OutputMsg 事件发送回 kafka 但我不知道如何控制键，只有值（在我的示例中为 OutputMsg）
改用Function<Message<InputMsg>, Message<OutputMsg>>。
入站消息中，key在msg.getHeaders().get(KafkaHeaders.RECEIVED_MESSAGE_KEY)；要在出站消息中设置密钥，请设置 KafkaHeaders.MESSAGE_KEY.