- message를 전송한 sender의 MDC정보를 consumer listener가 추가적으로 logging
- mdc정보의 생성/주입/초기화 주기를 잘 확인 할수 있어야함
-
ConcurrentKafkaListenerContainerFactory를 생성하는 bean에서 recordFilterStrategy를 정의
- 현재 thread의 mdc정보를 copy
- thread의 zipkin 관련 정보를 제외하고 초기화
- kafka message header에 주입한 MDC정보를 현재 thread의 MDC에 주입
- zipkin 정보로 인해, 약간의 filter단계가 필요했음
반응형
'emotional developer > detect-Java' 카테고리의 다른 글
Swagger Enum plugin (0) | 2020.10.20 |
---|---|
Springboot versionup 2.0.6 -> 2.1.3 (0) | 2020.10.19 |
Java Model Define (0) | 2020.10.19 |