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

Google Groups | Saravanan Tirugnanum | 4 months ago
  1. 0

    Clarification on Kafka Connect running in distributed mode - Production

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

    Re: Kafka producer metadata issue

    kafka-users | 5 months ago | Shekar Tippur
    org.apache.kafka.common.errors.TimeoutException: Batch containing 1 record(s) expired due to timeout while requesting metadata from brokers for test1-0
  3. 0

    schema-registry-start server get error

    GitHub | 6 months ago | nathan-zhu
    org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching topic metadata [2016-05-25 18:58:46,553] WARN caught end of stream exception (org.apache.zookeeper.server.NIOServerCnxn) EndOfStreamException: Unable to read additional data from client sessionid 0x154e78f4ba10001, likely client has closed socket
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    StoreTimeoutException when starting schema registry

    Google Groups | 2 years ago | Sigurd Knippenberg
    org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
  6. 0

    using confluent fromm kafka to hdfs: ERROR Task test-mysql-jdbc-autoincrement-source-0 threw an unc

    Google Groups | 7 months ago | Kotesh Banoth
    org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms. at org.apache.kafka.clients.producer.KafkaProducer$FutureFailure.<init>(KafkaProducer.java:686)*

    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    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