我正在尝试使用Replyingkafkatemplate，其中自动添加correlationid，但是当使用kafka连接器-Sink连接器将消息发布到Google pubsub时， header 丢失。仅存在消息有效负载。 有什么方法可以获取 pub sub 中的 header 吗？
最佳答案
如果您正在谈论Cloud Pub/Sub Kafka Connector ，那么它还不支持 headers。有一个outstanding pull request正在审查添加此功能。
关于java - 回复kafka模板连接 header (CorrelationId)未发送到Google pub sub，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/55738400/