You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Chris Egerton (Jira)" <ji...@apache.org> on 2021/02/11 02:47:00 UTC
[jira] [Resolved] (KAFKA-12182) Kafka connector is failing due to '
OffsetStorageWriter is already flushing' error
[ https://issues.apache.org/jira/browse/KAFKA-12182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Chris Egerton resolved KAFKA-12182.
-----------------------------------
Resolution: Duplicate
> 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
> Priority: Major
>
> 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)