@Log4j2 @Service @KafkaListener(id = "temp-id",topics = "#{'${spring.kafka.incoming.topic}'.split(',')}") public class Consumer { @KafkaHandler public void consume(Student student,@Header(KafkaHeaders.OFFSET) String offset) log.info("offset:" + offset + "Incoming info: "+student); } }