Kafka - 消费指定偏移量
发布时间
阅读量：
阅读量
Kafka - 指定offset进行消费
通过网络检索得知，若要从消息队列的起始位置开始处理数据，其核心实现代码大致如下：
String topicName = "A25";
//用于分配topic和partition
consumer.assign(Arrays.asList(new TopicPartition(topicName, 0)));
//不改变当前offset，指定从这个topic和partition的开始位置获取。
consumer.seekToBeginning(Arrays.asList(new TopicPartition(topicName, 0)));
执行20轮轮询操作，观察数据的消费结果：
for (int i = 0; i < 20; i++) {
ConsumerRecords<String, String> records = consumer.poll(100);
logger.info("records length = {}", records.count());
for (ConsumerRecord record : records) {
logger.info("topi全部评论 (0)
还没有任何评论哟~