org.springframework.messaging.MessagingException: Exception thrown while invoking MyApplication#myMessageSink[1 args]; nested exception is org.apache.avro.AvroRuntimeException: Malformed data. Length is negative: -27

Stack Overflow | neptoon | 8 months ago
tip
Click on the to mark the solution that helps you, Samebug will learn from it.
As a community member, you’ll be rewarded for you help.
  1. 0

    Spring Cloud Stream Kafka > consuming Avro messages from Confluent REST Proxy

    Stack Overflow | 8 months ago | neptoon
    org.springframework.messaging.MessagingException: Exception thrown while invoking MyApplication#myMessageSink[1 args]; nested exception is org.apache.avro.AvroRuntimeException: Malformed data. Length is negative: -27

    Root Cause Analysis

    1. org.springframework.messaging.MessagingException

      Exception thrown while invoking MyApplication#myMessageSink[1 args]; nested exception is org.apache.avro.AvroRuntimeException: Malformed data. Length is negative: -27

      at org.springframework.cloud.stream.binding.StreamListenerAnnotationBeanPostProcessor$StreamListenerMessageHandler.handleRequestMessage()
    2. org.springframework.cloud
      StreamListenerAnnotationBeanPostProcessor$StreamListenerMessageHandler.handleRequestMessage
      1. org.springframework.cloud.stream.binding.StreamListenerAnnotationBeanPostProcessor$StreamListenerMessageHandler.handleRequestMessage(StreamListenerAnnotationBeanPostProcessor.java:316)[spring-cloud-stream-1.1.0.RELEASE.jar:1.1.0.RELEASE]
      1 frame
    3. Spring Integration Core
      UnicastingDispatcher.doDispatch
      1. org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:109)[spring-integration-core-4.3.2.RELEASE.jar:4.3.2.RELEASE]
      2. org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:127)[spring-integration-core-4.3.2.RELEASE.jar:4.3.2.RELEASE]
      3. org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:116)[spring-integration-core-4.3.2.RELEASE.jar:4.3.2.RELEASE]
      4. org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:148)[spring-integration-core-4.3.2.RELEASE.jar:4.3.2.RELEASE]
      4 frames