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를 정의

    1. 현재 thread의 mdc정보를 copy
    2. thread의 zipkin 관련 정보를 제외하고 초기화
    3. kafka message header에 주입한 MDC정보를 현재 thread의 MDC에 주입
  • zipkin 정보로 인해, 약간의 filter단계가 필요했음
반응형