org.apache.kafka.connect.errors.ConnectException: Failed to fetch offsets.

If you like a tip written by other Samebug users, mark is as helpful! Marks help our algorithm provide you better solutions and also help other users.
tip

Spark was running out of memory.

tip

Spark ran out of memory

You have a different solution? A short tip here would help you and many other users who saw this issue last week.

  • 安装eclipse失败,求教_eclipse吧_百度贴吧
    via by Unknown author,
  • same error on shutdown
    via GitHub by austindkelly
    ,
  • startup exceptions
    via GitHub by jstrachan
    ,
    • org.apache.kafka.connect.errors.ConnectException: Failed to fetch offsets. at org.apache.kafka.connect.storage.OffsetStorageReaderImpl.offsets(OffsetStorageReaderImpl.java:81) at com.walmart.ei.oms.transformation.OMSSourceTask.start(OMSSourceTask.java:80) at org.apache.kafka.connect.runtime.WorkerSourceTask$WorkerSourceTaskThread.execute(WorkerSourceTask.java:341) at org.apache.kafka.connect.util.ShutdownableThread.run(ShutdownableThread.java:82) Caused by: org.apache.kafka.common.errors.InterruptException: Flush interrupted. at org.apache.kafka.clients.producer.KafkaProducer.flush(KafkaProducer.java:548) at org.apache.kafka.connect.util.KafkaBasedLog.readToEnd(KafkaBasedLog.java:192) at org.apache.kafka.connect.storage.KafkaOffsetBackingStore.get(KafkaOffsetBackingStore.java:112) at org.apache.kafka.connect.storage.OffsetStorageReaderImpl.offsets(OffsetStorageReaderImpl.java:78) ... 3 more Caused by: java.lang.InterruptedException at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:998) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1304) at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:231) at org.apache.kafka.clients.producer.internals.ProduceRequestResult.await(ProduceRequestResult.java:57) at org.apache.kafka.clients.producer.internals.RecordAccumulator.awaitFlushCompletion(RecordAccumulator.java:422) at org.apache.kafka.clients.producer.KafkaProducer.flush(KafkaProducer.java:546)

    Users with the same issue

    silex
    silex2 times, last one,
    marcbouvierdav
    marcbouvierdav24 times, last one,
    Adrien
    Adrien2 times, last one,
    filpgame
    filpgame2 times, last one,
    gamebusterz
    gamebusterz3 times, last one,
    24 more bugmates