org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing

Google Groups | Nabeel Moidu | 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

    Stream monitoring empty on Confluent Control center

    Google Groups | 7 months ago | Nabeel Moidu
    org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
  2. 0

    [Kafka Connect] Exception : Offset Storage Writer is already flushing

    Google Groups | 6 months ago | Sreejith S
    org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
  3. 0

    Exception when commiting offsets, Bulk Insert

    GitHub | 7 months ago | srijiths
    org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

    Root Cause Analysis

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

      OffsetStorageWriter is already flushing

      at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush()
    2. org.apache.kafka
      SourceTaskOffsetCommitter$1.run
      1. org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112)
      2. org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279)
      3. org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107)
      4. org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44)
      5. org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73)
      5 frames
    3. 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.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
      4. java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
      5. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
      6. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
      7. java.lang.Thread.run(Thread.java:745)
      7 frames