回复 kafka template connect headers(CorrelationId) 未发送到 Google pub sub

Question

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

Answer 1

如果您正在谈论 Cloud Pub/Sub Kafka Connector, then it does not yet support headers. There is an outstanding pull request 正在审查添加此功能。