org.springframework.messaging.MessageHandlingException: error occurred in message handler [org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler#1]; nested exception is java.util.concurrent.ExecutionException: org.springframework.kafka.core.KafkaProducerException: Failed to send; nested exception is org.apache.kafka.common.errors.TimeoutException: Batch Expired

GitHub | Franksha | 3 months ago
  1. 0

    GitHub comment 139#248699128

    GitHub | 3 months ago | Franksha
    org.springframework.messaging.MessageHandlingException: error occurred in message handler [org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler#1]; nested exception is java.util.concurrent.ExecutionException: org.springframework.kafka.core.KafkaProducerException: Failed to send; nested exception is org.apache.kafka.common.errors.TimeoutException: Batch Expired

    Root Cause Analysis

    1. org.springframework.kafka.core.KafkaProducerException

      Failed to send; nested exception is org.apache.kafka.common.errors.TimeoutException: Batch Expired

      at org.springframework.kafka.core.KafkaTemplate$1.onCompletion()
    2. org.springframework.kafka
      KafkaTemplate$1.onCompletion
      1. org.springframework.kafka.core.KafkaTemplate$1.onCompletion(KafkaTemplate.java:226)
      1 frame
    3. Apache Kafka
      Sender.run
      1. org.apache.kafka.clients.producer.internals.RecordBatch.done(RecordBatch.java:99)
      2. org.apache.kafka.clients.producer.internals.RecordBatch.maybeExpire(RecordBatch.java:136)
      3. org.apache.kafka.clients.producer.internals.RecordAccumulator.abortExpiredBatches(RecordAccumulator.java:220)
      4. org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:192)
      5. org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:128)
      5 frames
    4. Java RT
      Thread.run
      1. java.lang.Thread.run(Thread.java:745)
      1 frame