org.apache.kafka.connect.errors.ConnectException: Flush failed with non retriable exception.

GitHub | srijiths | 7 months ago
tip
Your exception is missing from the Samebug knowledge base.
Here are the best solutions we found on the Internet.
Click on the to mark the helpful solution and get rewards for you help.
  1. 0

    GitHub comment 14#244106269

    GitHub | 6 months ago | rmoff
    org.apache.kafka.connect.errors.ConnectException: Flush failed with non retriable exception.
  2. 0

    Exception when commiting offsets, Bulk Insert

    GitHub | 7 months ago | srijiths
    org.apache.kafka.connect.errors.ConnectException: Flush failed with non retriable exception.
  3. 0

    GitHub comment 14#244322334

    GitHub | 6 months ago | rmoff
    org.apache.kafka.connect.errors.ConnectException: Flush failed with non retriable exception.
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    GitHub comment 51#270832506

    GitHub | 2 months ago | simplesteph
    org.apache.kafka.connect.errors.ConnectException: Flush timeout expired with unflushed records: 560

    Root Cause Analysis

    1. org.apache.kafka.connect.errors.ConnectException

      Cannot finish flush messages within 10000

      at io.confluent.connect.elasticsearch.ElasticsearchWriter.flush()
    2. io.confluent.connect
      ElasticsearchSinkTask.flush
      1. io.confluent.connect.elasticsearch.ElasticsearchWriter.flush(ElasticsearchWriter.java:314)
      2. io.confluent.connect.elasticsearch.ElasticsearchSinkTask.flush(ElasticsearchSinkTask.java:137)
      2 frames
    3. org.apache.kafka
      WorkerTask.run
      1. org.apache.kafka.connect.runtime.WorkerSinkTask.commitOffsets(WorkerSinkTask.java:275)
      2. org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:155)
      3. org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:142)
      4. org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:140)
      5. org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:175)
      5 frames
    4. Java RT
      Thread.run
      1. java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
      2. java.util.concurrent.FutureTask.run(FutureTask.java:266)
      3. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
      4. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
      5. java.lang.Thread.run(Thread.java:745)
      5 frames