emotional developer/detect-Java
Kafaka consumer listener Sender MDC logging
성게군.
2020. 10. 20. 00:06
반응형
- message를 전송한 sender의 MDC정보를 consumer listener가 추가적으로 logging
- mdc정보의 생성/주입/초기화 주기를 잘 확인 할수 있어야함
-
ConcurrentKafkaListenerContainerFactory를 생성하는 bean에서 recordFilterStrategy를 정의
- 현재 thread의 mdc정보를 copy
- thread의 zipkin 관련 정보를 제외하고 초기화
- kafka message header에 주입한 MDC정보를 현재 thread의 MDC에 주입
- zipkin 정보로 인해, 약간의 filter단계가 필요했음
반응형