如何解决在使用Spring Cloud Stream发布到Kafka Topic之前如何在消息中添加标头
我刚刚意识到,一旦在Kafka Topic上收到的消息就会使标题松开。在将消息发布到Kafka Topic之前,是否可以在消息中添加标头,然后在消费者那里阅读? 我正在使用Java 11,Spring Cloud Hoxton.SR6,Spring 2.2.4,kafka_2.13-2.6.0。预先感谢!
解决方法
我认为发布问题还为时过早。非常简单。从HttpServletRequest或HttpRequest(spring)获取请求标头,然后在写入MessageChannel时,在传递标头的同时调用CopyHeaders方法。您也可以跳过不需要的内容。在消费者处,而不是自定义对象中,获得具有所有标题的Message对象
制作人
PATH
消费者
MessageBuilder.withPayload(message).copyHeaders(headersMap).build();
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。