Fátima Galera created KAFKA-12182: ------------------------------------- Summary: Kafka connector is failing due to ' OffsetStorageWriter is already flushing' error Key: KAFKA-12182 URL: https://issues.apache.org/jira/browse/KAFKA-12182 Project: Kafka Issue Type: Bug Components: KafkaConnect Environment: QAS Reporter: Fátima Galera
Hi kafka support We have a connector which is failing with below error "state": "FAILED", "worker_id": "xxxxxx:8083", "trace": "org.apache.kafka.connect.errors.ConnectException: OffsetStorageWriter is already flushing\n\tat org.apache.kafka.connect.storage.OffsetStorageWriter.beginFlush(OffsetStorageWriter.java:111)\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.commitOffsets(WorkerSourceTask.java:410)\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:239)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:175)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:219)\n\tat java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n" I have read below article about this issue, but this is old. Could you please let us know if we should implement these parameters? [https://stackoverflow.com/questions/55839310/debezium-is-failing-to-snapshot-big-table-size] Best regards and thanks Fátima -- This message was sent by Atlassian Jira (v8.3.4#803005)