本站内所有文档均为中英对照文档，点击中文可以显示英文。此提醒连续关闭5次后，将不再显示。

文档内容来源于 spring.io，由 springdoc.tech 翻译，版权归属于 SPRING.IO (Broadcom. Inc)。可供个人学习、研究，未经许可，不得进行转载或用于商业行为。

使用 `KafkaTemplate` 接收

ChatGPT-4o-mini 中英对照 Using KafkaTemplate to Receive Using KafkaTemplate to Receive

本节介绍如何使用 KafkaTemplate 接收消息。

从版本 2.8 开始，模板有四个 receive() 方法：

ConsumerRecord<K, V> receive(String topic, int partition, long offset);

ConsumerRecord<K, V> receive(String topic, int partition, long offset, Duration pollTimeout);

ConsumerRecords<K, V> receive(Collection<TopicPartitionOffset> requested);

ConsumerRecords<K, V> receive(Collection<TopicPartitionOffset> requested, Duration pollTimeout);
java

如您所见，您需要知道要检索的记录的分区和偏移量；每个操作都会创建（并关闭）一个新的 Consumer。

使用最后两种方法时，每条记录都是单独检索的，结果被组装成一个 ConsumerRecords 对象。在为请求创建 TopicPartitionOffset 时，仅支持正的、绝对的偏移量。