티스토리 뷰
java.lang.IllegalStateException: This error handler cannot process 'SerializationException's directly; please consider configuring an 'ErrorHandlingDeserializer' in the value and/or key deserializer
위의 오류처럼 뭔가 설정상의 오류가 있는 것 같다.
package io.hhplus.concert.config;
import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.common.serialization.StringDeserializer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory;
import org.springframework.kafka.core.ConsumerFactory;
import org.springframework.kafka.core.DefaultKafkaConsumerFactory;
import org.springframework.kafka.support.serializer.ErrorHandlingDeserializer;
import org.springframework.kafka.support.serializer.JsonDeserializer;
import java.util.HashMap;
import java.util.Map;
@Configuration
public class KafkaConsumerConfig {
@Bean
public ConsumerFactory<String, Object> consumerFactory() {
Map<String, Object> config = new HashMap<>();
config.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9093");
config.put(ConsumerConfig.GROUP_ID_CONFIG, "group_1");
config.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
config.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, ErrorHandlingDeserializer.class.getName());
config.put(ErrorHandlingDeserializer.VALUE_DESERIALIZER_CLASS, JsonDeserializer.class.getName());
config.put(JsonDeserializer.TRUSTED_PACKAGES, "io.hhplus.concert.domain.message,java.util,java.lang");
config.put(JsonDeserializer.VALUE_DEFAULT_TYPE, "io.hhplus.concert.domain.message.PaymentMessage");
return new DefaultKafkaConsumerFactory<>(config);
}
@Bean
public ConcurrentKafkaListenerContainerFactory<String, Object> kafkaListenerContainerFactory() {
ConcurrentKafkaListenerContainerFactory<String, Object> factory = new ConcurrentKafkaListenerContainerFactory<>();
factory.setConsumerFactory(consumerFactory());
return factory;
}
}
설정 중에는 대부분 Deserializer 부분에서 오류가 많이 발생 했는데, 위처럼 해결했다.
'dev_공부일지 > JPA 에러 정리' 카테고리의 다른 글
org.springframework.mail.MailSendException: Mail server connection failed. Failed messages: jakarta.mail.NoSuchProviderException: smtp (0) | 2024.03.25 |
---|---|
and token '=', mismatched input '=', (JPQL 특정 문자열 상위) (0) | 2024.03.14 |
예외 공통 처리 제대로 안될 때... (진짜 바보짓) (0) | 2024.03.12 |
No enum constant javax.lang.model.element.Modifier.SEALED 오류 해결 (6) | 2024.03.12 |
예외처리 만들기 (0) | 2024.03.11 |
공지사항
최근에 올라온 글
최근에 달린 댓글
- Total
- Today
- Yesterday
링크
TAG
- 항해플러스
- 예외처리
- reject
- 향해99
- react실행
- 향해플러스
- 인터셉터
- JPA
- BindingResult
- React
- Java
- 로그인
- 스프링부트
- 백엔드 개발자 공부
- 스프링공부
- 항해99
- HTTP
- 백엔드 개발자 역량
- 리터럴
- Intercepter
- SpringBoot
- rejectValue
- 컨트
- jpa api
- 향해플러스백엔드
- thymleaf
- filter
- hypertexttransferprotocol
- exception
- ArgumentResolver
일 | 월 | 화 | 수 | 목 | 금 | 토 |
---|---|---|---|---|---|---|
1 | 2 | 3 | 4 | 5 | ||
6 | 7 | 8 | 9 | 10 | 11 | 12 |
13 | 14 | 15 | 16 | 17 | 18 | 19 |
20 | 21 | 22 | 23 | 24 | 25 | 26 |
27 | 28 | 29 | 30 | 31 |
글 보관함