kafka教程-springboot消费者指定分区(partition)和偏移量(offset)

在 kafka教程-springboot实现简单消费者 基础上增加下面代码:

@KafkaListener(topicPartitions = {
        @TopicPartition(
                topic = "userlog",
                partitionOffsets = @PartitionOffset(partition = "0", initialOffset = "8"))
})
public void onMessage(ConsumerRecord<?, ?> record) {
    //获取消费者组
    String groupId= KafkaUtils.getConsumerGroupId();
    // 消费的哪个topic、partition的消息,打印出消息内容
    System.out.println("消费:topic:"+record.topic()+
            "-partition:"+record.partition()+
            "-offset:"+record.offset()+
            "-value:"+record.value() +
            "-"+groupId);
}

原文出处:/show_1IXNLSfPN3K.html