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

GitHub | rmoff | 3 months ago
  1. 0

    GitHub comment 14#244106269

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

    Exception when commiting offsets, Bulk Insert

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

    GitHub comment 14#244322334

    GitHub | 3 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

    Exception when commiting offsets, Bulk Insert

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

    GitHub comment 3#229846258

    GitHub | 5 months ago | ewencp
    org.apache.kafka.connect.errors.ConnectException: Flush failed with non retriable exception.

    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.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