spring cloud streams 2.2+kafka binder embeddedheaders在appd添加本机singularity报头后,当本机报头出现时不会回退

8wtpewkr  于 2021-07-13  发布在  Java
关注(0)|答案(0)|浏览(229)

当我查看springcloud流的源提交时,注解指出,如果可以检测到嵌入的头,那么即使存在本机头,嵌入头也会生效。
当appd被插入到我的服务中时,我遇到了这个问题,服务正在使用嵌入的头来流式传输内容,而kafka消费者正在尝试使用嵌入的头来读取该内容。
但是,代码不能正确地处理这个问题,并且当存在本机头时,embeddedheaders会被忽略,最终会在jackson中出现json解析错误,在jackson中,它试图对嵌入头进行摘要。 Spring 团队,请解决这个问题:-)
注意:虽然似乎有一种方法可以关闭singularity头,但是spring云流代码似乎仍然应该被纠正。我甚至检查了最新的spring代码,它仍然存在这个问题。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题