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

GitHub | srijiths | 4 months ago
  1. 0

    Exception when commiting offsets, Bulk Insert

    GitHub | 4 months ago | srijiths
    org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
  2. 0

    Stream monitoring empty on Confluent Control center

    Google Groups | 4 months ago | Nabeel Moidu
    org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing
  3. Speed up your debug routine!

    Automated exception search integrated into your IDE

  4. 0

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

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

    ERROR Unhandled exception when committing WorkerSourceTask{id=name-source-0} ...

    Google Groups | 5 months ago | Andrew Pennebaker
    org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing connect_1 | at org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:112) connect_1 | at org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:279) connect_1 | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.commit(SourceTaskOffsetCommitter.java:107) connect_1 | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter.access$000(SourceTaskOffsetCommitter.java:44) connect_1 | at org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter$1.run(SourceTaskOffsetCommitter.java:73) connect_1 | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) connect_1 | at java.util.concurrent.FutureTask.run(FutureTask.java:266)

    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

      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