봄 클라우드 스트림 카프카 - EmbeddedHeadersMessageConverter - java.lang.StringIndexOutOfBoundsException : 주제에서 읽을 봄 클라우드 스트림 카프카를 사용

Question

에서 문자열 색인이 범위를 벗어 나는 봄 부팅 응용 프로그램이 (APP0).

은 해당 항목에 메시지를 생성이 다른 애플 리케이션 (APP1, APP2)이 있습니다.

예컨대

public interface OrderSource{ 

    String OUTPUT_PAYMENT = Topic.PAYMENT_RESULTS; 

    @Output(OrderSource.OUTPUT_PAYMENT) 
    MessageChannel output(); 

:

APP1가 인터페이스 OrderSource를 사용하여 메시지 게시 이때

orderSource.output().send(MessageBuilder.withPayload(order).build(), 500); 

을 APP0 아무 문제없이 APP1에서 메시지를 판독한다. 내가 EmbeddedHeadersMessageConverter에서 다음과 같은 예외를 관찰하고이 경우

ListenableFuture<SendResult<Integer, String>> delivery = kafkaTemplate.send(Topic.PAYMENT_RESULTS, "{ ... }"); 
try { 
    SendResult<Integer, String> result = delivery.get(timeout, TimeUnit.MILLISECONDS); 

:

java.lang.StringIndexOutOfBoundsException: String index out of range: 152 
    at java.lang.String.checkBounds(Unknown Source) ~[na:1.8.0_91] 
    at java.lang.String.<init>(Unknown Source) ~[na:1.8.0_91] 
    at org.springframework.cloud.stream.binder.EmbeddedHeadersMessageConverter.oldExtractHeaders(EmbeddedHeadersMessageConverter.java:135) ~[spring-cloud-stream-1.1.0.RELEASE.jar:1.1.0.RELEASE] 
    at org.springframework.cloud.stream.binder.EmbeddedHeadersMessageConverter.extractHeaders(EmbeddedHeadersMessageConverter.java:105) ~[spring-cloud-stream-1.1.0.RELEASE.jar:1.1.0.RELEASE] 

을 분명히 그것의 페이로드에서 헤더를 추출하기 위해 노력하고있다

APP2는 KafkaTemplate를 사용하여 메시지를 게시 메시지. 두 메시지 소스 (KafkaTemplate 및 OrderSource)를 지원하는 동안이 예외가 발생하지 않게하려면 어떻게해야합니까?

Answer 1

비 Spring-Cloud-Stream 앱과 통신하려면 소비자의 headerMode을 raw으로 구성해야합니다.

app1에 대해서도 동일한 작업을 수행해야하므로 헤더를 포함하지 않습니다.

consumer properties 및 producer properties을 참조하십시오.