package kr.wisestone.owl.config.kafka;
|
|
import kr.wisestone.owl.util.CommonUtil;
|
import org.apache.kafka.clients.consumer.ConsumerRecord;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.kafka.annotation.KafkaListener;
|
import org.springframework.messaging.simp.SimpMessagingTemplate;
|
import org.springframework.stereotype.Service;
|
|
import java.util.Map;
|
|
@Service
|
public class KafkaReceiver {
|
private static final Logger log = LoggerFactory.getLogger(KafkaReceiver.class);
|
|
@Autowired
|
private SimpMessagingTemplate simpMessagingTemplate;
|
|
@KafkaListener(topics = "#{'${kafka.common.topic}'}")
|
public void receive(ConsumerRecord<?, ?> consumerRecord) {
|
Map<String, Object> messageMap = (Map<String, Object>) consumerRecord.value();
|
|
CommonUtil.sendWebSocketMessage(this.simpMessagingTemplate, messageMap);
|
}
|
}
|