卡夫卡模板接收

本节介绍如何使用卡夫卡模板接收信息。spring-doc.cadn.net.cn

从2.8版本开始,模板包含四个接收()方法:spring-doc.cadn.net.cn

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);

如你所见,你需要知道需要检索的记录的分区和偏移量;一个新的消费者为每个作创建(并闭合)。spring-doc.cadn.net.cn

在后两种方法中,每个记录单独检索并汇聚成消费者唱片对象。 在创建主题分区偏移请求时,只支持正偏移量和绝对偏移量。spring-doc.cadn.net.cn