Spring Integration kafka出站通道适配器

Question

我有一个模型对象，它是在多次转换和解析之后填充的。现在，我需要使用spring集成将模型中的消息属性发送给kafka。我可以使用messageKey方法构造键，但如何从m.getPayload（）之类的模型中获取实际消息。getMessage（）并将其发送给Kafka。

                .publishSubscribeChannel(pubSub -> pubSub
                        .subscribe(flow -> flow
                            .bridge(e -> e.order(Ordered.HIGHEST_PRECEDENCE))
                            .handle(Kafka.outboundChannelAdapter(kafkaTemplate).
                                    messageKey(m -> ((AcarsFlightInformation) m.getPayload()).getFlightNbr()).topic(acarsKafkaTopic)))

Answer 1

不完全清楚您在问什么。发送到适配器的消息的有效负载成为生产者记录的值。

我想你要问的是，你只想发送部分有效载荷。

在<代码>之前使用标题富集器和转换器。句柄。。。

.enrichHeaders(h -> h.headerExpression(KafkaHeaders.MESSAGE_KEY, "payload.flightNumber")
.transform("payload.message")
.handle(Kafka.outboundChannelAdapter(kafkaTemplate)
      .topic(acarsKafkaTopic))
.get();

适配器将为密钥查找该标头。