DLQ에 예외가 포함되지 않았습니다.

Question

kafka 바인더가있는 스프링 클라우드 스트림을 설정했습니다. 또한 DLQ를 사용 가능하게 설정하고 here과 같이 예외 메시지를 캡처하도록 headerMode를 설정했습니다. 그러나 예외가있을 때 예외 정보없이 내 카프카 주제의 메시지 만 볼 수 있습니다. 내 application.yml는 (0.11 이전) - 카프카에게 스프링 클라우드 스타터 스트림이

spring: 
    application: 
    name: Sample Stream 
    cloud: 
    stream: 
     defaultBinder: kafka 
     default: 
     consumer: 
      headerMode: raw 
     producer: 
      headerMode: raw 
     kafka: 
     binder: 
      zkNodes: zookeeper 
      brokers: kafka 
     bindings: 
      input: 
      consumer: 
       enableDlq: true 
       dlqName: testDLQ 

내가 버전 1.2.1.RELEASE를 사용하고 같은

Answer 1

카프카를 보이는 헤더에 대한 지원이 없습니다; kafka11 바인더 (1.3.x 버전, 커널 2.0.x)는 토끼 바인더와 유사한 헤더에 그러한 정보를 (포함하도록 향상 될 수 repulishToDlq 옵션을 선택합니다.

나는 단지 opened an issue for this 당신이 그것을 따르십시오.