Update VideoService.java

Author: DucBaoUIT

src/main/java/com/programming/videoService/service/VideoService.java

@@ -87,14 +87,14 @@ public class VideoService {
     public VideoService() {
         // Kafka Producer Configuration
         Properties producerProps = new Properties();
-        producerProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
+        producerProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "192.168.120.131:9092");
         producerProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
         producerProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
         this.kafkaProducer = new KafkaProducer<>(producerProps);
 
         // Kafka Consumer Configuration
         Properties consumerProps = new Properties();
-        consumerProps.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
+        consumerProps.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "192.168.120.131:9092");
         consumerProps.put(ConsumerConfig.GROUP_ID_CONFIG, "video-genres-group");
         consumerProps.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
         consumerProps.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
@@ -521,6 +521,10 @@ private void saveToDatabase(Recommender recommender) {
     public void uploadReport(String videoId, String msg, String userId) {
         Report report = new Report(videoId, msg, userId);
         mongoTemplate.save(report);
+        MDC.put ("type", "videoservice");
+        MDC.put ("action", "report");
+        MDC.put ("videoid", videoId.toString());
+        logger.info ("User " + userId.toString() + " report " + msg);
     }
 
     public List<String> getReportsWithHighFrequencyVideoIds() {