[
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)
