如果我在一个线程中运行
消费者正在Web服务上运行,用于不断地从队列中拉取数据,并且永远不应停止执行。此外,该服务没有空闲或挂起状态。在Kafka文档中指出,只有当kafka消费者被另一个线程阻塞时才会抛出该异常,但这种情况永远不会发生。 https://kafka.apache.org/0100/javadoc/org/apache/kafka/common/errors/WakeupException.html Kafka版本0.10.0.0
kafka
消费者,并且不从外部进行操作,例如将消费者置于休眠或唤醒它,则有必要正确处理WakeupException
吗?以及如何处理它的好方法是什么?消费者正在Web服务上运行,用于不断地从队列中拉取数据,并且永远不应停止执行。此外,该服务没有空闲或挂起状态。在Kafka文档中指出,只有当kafka消费者被另一个线程阻塞时才会抛出该异常,但这种情况永远不会发生。 https://kafka.apache.org/0100/javadoc/org/apache/kafka/common/errors/WakeupException.html Kafka版本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();
}
问候,Rakesh