Add ELK

Author: DucBaoUIT

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

@@ -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() {

src/main/resources/application.properties

@@ -27,3 +27,6 @@ spring.mail.properties.mail.smtp.starttls.enable=true
 spring.redis.host=10.40.0.5
 spring.redis.port=6379
 spring.redis.password=123456
+
+# logstash
+logging.config=classpath:logback-spring.xml

src/main/resources/application.yml

@@ -10,7 +10,7 @@ spring:
 
 
   kafka:
-    bootstrap-servers: localhost:9092
+    bootstrap-servers: 192.168.120.131:30392
     producer:
       key-serializer: org.apache.kafka.common.serialization.StringSerializer
       value-serializer: org.springframework.kafka.support.serializer.JsonSerializer

src/main/resources/logback-spring.xml

@@ -0,0 +1,11 @@
+<configuration>
+    <appender name="LOGSTASH" class="net.logstash.logback.appender.LogstashTcpSocketAppender">
+        <destination>192.168.120.213:5070</destination>
+        <encoder class="net.logstash.logback.encoder.LogstashEncoder">
+        </encoder>
+    </appender>
+
+    <root level="INFO">
+        <appender-ref ref="LOGSTASH"/>
+    </root>
+</configuration>