org.apache.kafka.common.errors.TimeoutException: Batch Expired

Google Groups | Saravanan Tirugnanum | 9 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

    Clarification on Kafka Connect running in distributed mode - Production

    Google Groups | 9 months ago | Saravanan Tirugnanum
    org.apache.kafka.common.errors.TimeoutException: Batch Expired

    Root Cause Analysis

    1. org.apache.kafka.common.errors.TimeoutException

      Batch Expired

      at org.apache.kafka.connect.storage.KafkaOffsetBackingStore$SetCallbackFuture.get()
    2. org.apache.kafka
      ShutdownableThread.run
      1. org.apache.kafka.connect.storage.KafkaOffsetBackingStore$SetCallbackFuture.get(KafkaOffsetBackingStore.java:207)
      2. org.apache.kafka.connect.storage.KafkaOffsetBackingStore$SetCallbackFuture.get(KafkaOffsetBackingStore.java:140)
      3. org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:284)
      4. org.apache.kafka.connect.runtime.WorkerSourceTask$WorkerSourceTaskThread.execute(WorkerSourceTask.java:370)
      5. org.apache.kafka.connect.util.ShutdownableThread.run(ShutdownableThread.java:82)
      5 frames