dev

evps-comm-server/build.gradle

@@ -29,6 +29,7 @@ dependencies {
     implementation 'org.springframework.boot:spring-boot-starter-aop'
 
     implementation 'org.springframework.kafka:spring-kafka'
+    implementation 'com.fasterxml.jackson.core:jackson-databind'
 
     implementation 'org.mybatis.spring.boot:mybatis-spring-boot-starter:2.2.0'
     implementation 'org.mariadb.jdbc:mariadb-java-client'

evps-common/build.gradle

@@ -18,6 +18,7 @@ dependencies {
     // lombok 라이브러리 추가 끝
 
     implementation 'io.netty:netty-all:4.1.52.Final'
+    implementation 'com.fasterxml.jackson.core:jackson-databind'
 
     testImplementation platform('org.junit:junit-bom:5.10.0')
     testImplementation 'org.junit.jupiter:junit-jupiter'

evps-common/src/main/java/com/evps/common/kafka/dto/EvpsPhaseInfo.java

@@ -1,5 +1,6 @@
 package com.evps.common.kafka.dto;
 
+import com.fasterxml.jackson.annotation.JsonIgnore;
 import lombok.*;
 
 @Data
@@ -10,23 +11,25 @@ public class EvpsPhaseInfo {
     /**
      * 교차로 순서(1,...,N)
      */
+    @JsonIgnore
     private Integer seqNo;
     /**
      * 교차로 ID
      */
+    @JsonIgnore
     private Long nodeId;
     /**
      * 링번호(1:A링, 2:B링)
      */
     private Integer ring;
-    /**
-     * 현시번호(1~8)
-     */
-    private Integer phaseNo;
     /**
      * 맵 번호(0:일반제, 1~5:시차제, 6:전용맵)
      */
     private Integer planClass;
+    /**
+     * 현시번호(1~8)
+     */
+    private Integer phaseNo;
     /**
      * 이동류번호(1-16, 17, 18)
      */

evps-consumer/src/main/java/com/evps/consumer/service/KafkaUticEvpsConsumerWorker.java

@@ -37,7 +37,8 @@ public class KafkaUticEvpsConsumerWorker implements MessageListener<String, Stri
             else {
                 log.error("Unknown Utic Evps Kafka Key: {}, {}", record.key(), record.value());
             }
-        } catch (JsonProcessingException e) {
+        }
+        catch (JsonProcessingException e) {
             throw new RuntimeException(e);
         }
     }