在 spring-cloud-stream-kafka binder 中访问 RecordMetadata：如何指定 recordMetadataChannel

Question

我正在使用 Spring Cloud Stream Kafka binder 编写 Kafka Producer 和 Consumer。我想在生产者和消费者中访问以下信息

a) 主题
b) 分区
b) 偏移量

我确实检查了文档，但我真的找不到在哪里完成这项工作。我在文档中看到的只是将recordMetadataChannel 指定为生产者/消费者配置的一部分。有人会指出我是如何做到这一点的任何示例吗？

Answer 1

发送到该频道的消息头中的RecordMetadata 包含该信息。

见this answer。