回复kafka模板连接标头（CorrelationId）不会发送到Google pub sub

Question

我正在尝试使用Replyingkafkatemplate，其中自动添加了correlationid，但是当使用kafka connector-Sink连接器将消息发布到Google pubsub时，标题丢失了。仅存在消息有效负载。有没有办法在pub子中获取标题？

Answer 1

如果你在谈论Cloud Pub/Sub Kafka Connector，那么它还不支持标题。有一个outstanding pull request正在审查中添加此功能。