owl-local

jhjang

2021-10-14 d680ff9fa4298ad3c0cd12f5f9d87f6c51110480

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
package kr.wisestone.owl.config.kafka;
 
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Service;
 
import java.util.Map;
 
@Service
public class KafkaSender {
    private static final Logger log = LoggerFactory.getLogger(KafkaSender.class);
 
    @Autowired
    private KafkaTemplate<String, Object> kafkaTemplate;
 
    public void send(String topic, Map<String, Object> message) {
        if(kafkaTemplate != null)
            this.kafkaTemplate.send(topic, message);
    }
}