package demo.kafka;

import org.apache.kafka.clients.producer.ProducerRecord;
import org.springframework.kafka.core.KafkaTemplate;

public class PatrolNotifyProducer {
  private KafkaTemplate kafkaTemplate;
  private static final String TOPIC = "patrol-notify-topic";

  public void sendRecord(PatrolNotifyVo vo) {
    ProducerRecord<String, PatrolNotifyVo> record = new ProducerRecord<>(TOPIC, vo);
    kafkaTemplate.send(record);
  }

  public void sendJson(PatrolNotifyVo vo) {
    String json = JSON.toJSONString(vo);
    kafkaTemplate.send(TOPIC, json);
  }
}
