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