이 에러는 카프카 스트림즈 내부에서 null 메시지 값에 대한 처리를 제대로 못해서 나오는 이슈이다.
그러므로 KStream에서 filter로 null 메시지 값을 삭제하여 처리하면 된다.
KTable<Windowed<String>, Long> KT01 = myStream
.filter((k, v) -> v != null) // null value 제거
...
반응형
'빅데이터 > Kafka' 카테고리의 다른 글
| 카프카 스트림즈의 commit.interval.ms옵션 (2) | 2021.04.15 |
|---|---|
| 초~중급자를 위한 [아파치 카프카 애플리케이션 개발] 서적을 출간하였습니다. (12) | 2021.04.11 |
| 카프카 스트림즈 suppress() 사용할 때 ClassCastException 문제 (0) | 2021.04.06 |
| 카프카 스트림즈 애플리케이션 초기화 명령 (0) | 2021.03.31 |
| local kafka single broker 띄우기 with 도커 (0) | 2021.03.05 |
| 특정 시점(날짜+시간)의 레코드부터 가져오도록 설정하기. (2) | 2021.03.03 |
