小编Rak*_*iya的帖子

如果我kafka在线程内运行消费者而不从外部操作它，例如让消费者进入睡眠状态或唤醒他，是否有必要WakeupException正确处理？什么是处理它的好方法？

消费者正在 Web 服务上运行以不断地从队列中提取数据，并且永远不应该停止这样做。此外，该服务没有空闲或挂起状态。在 Kafka 的文档中指出只有当 kafka 消费者被另一个线程阻塞时才会抛出异常，但这永远不会发生。https://kafka.apache.org/0100/javadoc/org/apache/kafka/common/errors/WakeupException.html

卡夫卡版本 0.10.0.0

catch (WakeupException e) {
    LOG.info("Kafka Consulmer wakeup exception");
    // Ignore exception if closing
    if (!closed.get()) {
        throw e;
    }
} finally {
    consumer.close();
}

问候， 拉克什