Spring Boot로 Kafka Cloud에 연결하여 Json 데이터 주고 받기 (Callback 함수 및 Shutdown Hook)

Spring Boot로 Kafka Cloud에 연결하여 Json 데이터 주고 받기 (Callback 함수 및 Shutdown Hook)

서론 지난 글에서 Kafka cloud에 연결하여 String으로 메시지를 주고 받았었다. 이번에는 Json으로 데이터를 주고 받는 코드를 구현할 것이다. 만약 Kakfa Cloud에 연결하기 위해 Configuration 설정하는 법이 알고 싶다면 지난 글을 참고하시길 바란다. https://bascat-code.tistory.com/21 Spring Boot로 Kafka cloud(Confluent, Conduktor 등)에 연결하여 데이터 주고 받기 (Configuration 방법 2가지) 서론 spring Boot를 사용하여 kafka에 연결하여 데이터를 주고 받으려고 Reference 자료들을 검색해보는데, 대부분의 자료들이 localhost:9092에 접속하여 로컬 컴퓨터에 있는 Kafka를 ..

  • format_list_bulleted Web Development/Spring
  • · 2024. 3. 3.
  • textsms
Java의 특정 Class를 통째로 또는 Enum, Json array, Point.class를 deserialize 하기

Java의 특정 Class를 통째로 또는 Enum, Json array, Point.class를 deserialize 하기

역직렬화하는 과정에서 ClassCastException이 뜬 것을 경험했다면, 잘 찾아오셨다. 각 데이터 타입별로 역직렬화하는 방법을 간략하게 소개하고자 한다. 서론 - Json을 역직렬화할 때 겪는 문제 MSA에서 각 서비스간 비동기 메세지를 주고 받을 때 Json 형식으로 데이터를 주로 보내게 된다. Json으로 보낼 때는 Java 객체의 정보를 직렬화(serialization)하여 보내고, Json으로 받으면 다시 역직렬화(deserialization)하여 java 객체로 돌려놓게 된다. java에서는 아래 dependency를 사용하면 json을 java로 쉽게 매핑 할 수 있다. implementation 'org.json:json:20230227' 해당 dependency는 JSONObject..

  • format_list_bulleted Web Development/Java
  • · 2024. 2. 25.
  • textsms