kafka 에러 핸들링
-
SpringBoot와 Kafka 연동 시 발생한 ErrorHandlingDeserializer 관련 오류Apache Kafka/오류 해결 2024. 1. 14. 23:27
문제 스프링부트에서 STOMP를 활용한 채팅방을 구현하기 위해 기존 In memory broker 방식에서 External broker 중 하나인 Kafka를 통해 아래 형태의 메시지를 전달하려는데, @Getter @NoArgsConstructor @ToString public class Message { @NotNull private MessageType type; private String roomId; @NotNull private String sender; @NotNull private String message; @Builder private Message(MessageType type, String roomId, String sender, String message) { this.type = ..