org.apache.kafka.connect.errors.ConnectException

There are no available Samebug tips for this exception. Do you have an idea how to solve this issue? A short tip would help users who saw this issue last week.

  • Connect Distributed - Wont start after faulty connector config submitted
    via by Steven Deutscher-Kobayashi,
    • 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) at java.lang.Thread.run(Thread.java:745)
    No Bugmate found.