package demo.kafka;

import org.springframework.kafka.annotation.KafkaListener;

public class PatrolNotifyListener {
  @KafkaListener(topics = "patrol-notify-topic", groupId = "patrol-group")
  public void handle(String message) {
    PatrolNotifyVo vo = JSONObject.parseObject(message, PatrolNotifyVo.class);
  }
}
