kafka org.apache.kafka.common.errors.SerializationException: Size of data received by IntegerDeserializer is not 4 에러

이주희·2023년 11월 29일
0

kafka consumer에 IntegerDeserializer 로 설정을 했으나 producer에서 int가 아닌 데이터를 받게 됐을 때 나오는 에러

  • Producer에서 해당하는 key나 value값을 Int로 동일하게 Serialize해서 보내는지 확인
  1. props.setProperty(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, IntegerSerializer.class.getName());

  2. KafkaProducer<Integer, String>

  3. ProducerRecord<Integer,String>

3가지 확인해본다..!

  • 동일한 topic의 key나 value에 타입을 바꿔서 보내는지 확인
    이전 message도 같이 전송되므로 topic을 새로 만들어서 시도

0개의 댓글