[Java]Spring Cloud Stream 에서 Kafka 메시지 헤더 이용하는 방법 외
Kafka 메시지 처리를 위해 Spring Cloud Stream 을 이용하고 있고 Spring Cloud Stream 3.* 대로 올리면서 functional style 로 기존 소스 수정했었던 얘기 예전에 간단하게 적은 적 있었었다. 메시지 추가된게 있어서 간만에 코딩하게 되었는데 기존 메시지 포맷과 다른 몇 가지 점(json 배열 타입, nested 구조 등) 있어서 관련해서 메모해본다. 기존 메시지 포맷 { "key1": "val1", "key2": "val2", ... } 추가된 메시지 포맷 [ { "key1": "val1", "key2": "val2", "group1" : { ... }, "group2": { ... }, ... }, { "key1": "val1", "key2": "val2",..