org.apache.kafka.common.errors.InterruptException: Flush interrupted.

Google Groups | Saravanan Tirugnanum | 4 months ago
  1. 0

    Clarification on Kafka Connect running in distributed mode - Production

    Google Groups | 4 months ago | Saravanan Tirugnanum
    org.apache.kafka.common.errors.InterruptException: Flush interrupted.
  2. 0

    安装eclipse失败,求教_eclipse吧_百度贴吧

    baidu.com | 3 months ago
    java.lang.RuntimeException: java.lang.InterruptedException
  3. Speed up your debug routine!

    Automated exception search integrated into your IDE

  4. 0

    getting "Handshake response not received." after closing websocket

    Stack Overflow | 1 year ago | copolii
    javax.websocket.DeploymentException: Handshake response not received.

  1. maxxi 2 times, last 2 weeks ago
  2. Aria Pahlavan 6 times, last 2 weeks ago
  3. rube 4 times, last 2 months ago
  4. bpbhat77 10 times, last 3 months ago
  5. davidvanlaatum 10 times, last 3 months ago
8 more registered users
2 unregistered visitors
Not finding the right solution?
Take a tour to get the most out of Samebug.

Tired of useless tips?

Automated exception search integrated into your IDE

Root Cause Analysis

  1. java.lang.InterruptedException

    No message provided

    at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly()
  2. Java RT
    CountDownLatch.await
    1. java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:998)
    2. java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1304)
    3. java.util.concurrent.CountDownLatch.await(CountDownLatch.java:231)
    3 frames
  3. Apache Kafka
    KafkaProducer.flush
    1. org.apache.kafka.clients.producer.internals.ProduceRequestResult.await(ProduceRequestResult.java:57)
    2. org.apache.kafka.clients.producer.internals.RecordAccumulator.awaitFlushCompletion(RecordAccumulator.java:422)
    3. org.apache.kafka.clients.producer.KafkaProducer.flush(KafkaProducer.java:546)
    3 frames
  4. org.apache.kafka
    OffsetStorageReaderImpl.offsets
    1. org.apache.kafka.connect.util.KafkaBasedLog.readToEnd(KafkaBasedLog.java:192)
    2. org.apache.kafka.connect.storage.KafkaOffsetBackingStore.get(KafkaOffsetBackingStore.java:112)
    3. org.apache.kafka.connect.storage.OffsetStorageReaderImpl.offsets(OffsetStorageReaderImpl.java:78)
    3 frames
  5. com.walmart.ei
    OMSSourceTask.start
    1. com.walmart.ei.oms.transformation.OMSSourceTask.start(OMSSourceTask.java:80)
    1 frame
  6. org.apache.kafka
    ShutdownableThread.run
    1. org.apache.kafka.connect.runtime.WorkerSourceTask$WorkerSourceTaskThread.execute(WorkerSourceTask.java:341)
    2. org.apache.kafka.connect.util.ShutdownableThread.run(ShutdownableThread.java:82)
    2 frames