[트러블슈팅] key.serializer 누락됐을 때 Kafka 메시지 전송 실패

🐛 문제 현상

Kafka 메시지를 전송하려고 할 때 아래와 같은 오류가 발생했다.

Invalid value null for configuration key.serializer: must be non-null

 

 

🔍 원인 분석

Kafka는 메시지를 전송하기 위해 key와 value를 직렬화해야 하며, 반드시 두 가지 설정이 필요하다.

• key.serializer → 보통 org.apache.kafka.common.serialization.StringSerializer
• value.serializer → 보통 org.apache.kafka.support.serializer.JsonSerializer

하지만 현재 KafkaTemplate을 구성할 때 이 설정들이 명시되어 있지 않아서 오류가 발생했다.

 

 

🔍 해결 방법

Kafka Producer 설정 클래스(KafkaProducerConfig)에서 ProducerFactory에 설정을 명시적으로 추가했다.

✅ 수정 전 (누락된 설정)

new DefaultKafkaProducerFactory<>(new HashMap<>()) // key.serializer 없음

✅ 수정 후

@Bean
public ProducerFactory<String, KafkaMessage<StockDecreasePayload>> kafkaMessageProducerFactory() {
    Map<String, Object> props = new HashMap<>();
    props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
    props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
    props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class);
    return new DefaultKafkaProducerFactory<>(props);
}

@Bean
public KafkaTemplate<String, KafkaMessage<StockDecreasePayload>> kafkaTemplate() {
    return new KafkaTemplate<>(kafkaMessageProducerFactory());
}

 

 

💡 추가 팁

Spring Boot의 application.yml이나 .properties에 설정하더라도, 직접 생성한 KafkaTemplate에는 코드에서 명시해야 적용이 된다.
@EnableKafka 만으로는 자동으로 적용되지 않는다.