|
该版本仍在开发中，尚未被视为稳定。对于最新稳定版本，请使用 Spring for Apache Kafka 4.0.0！ |
用卡夫卡模板接收
本节介绍如何使用卡夫卡模板接收信息。
从2.8版本开始，模板包含四个接收（）方法：
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);如你所见，你需要知道需要检索的记录的分区和偏移量;一个新的消费者为每个作创建（并闭合）。
在后两种方法中，每个记录单独检索并汇聚成消费者唱片对象。
在创建主题分区偏移请求时，只支持正偏移量和绝对偏移量。