Spring Cloud Stream Kafka - EmbeddedHeadersMessageConverter - StringIndexOutOfBoundsException：文字列インデックスが範囲外です

Question

Spring Cloud Stream Kafkaを使用してトピックから読み込むSpringブートアプリケーション（app0）があります。

そのトピックにメッセージを生成する2つのアプリ（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を参照してください。