class MissingTopicClassifier implements QueryErrorClassifier {

  @Override
  public Type classify(final Throwable e) {
    final Type type = e instanceof MissingSourceTopicException ? Type.USER : Type.UNKNOWN;

    if (type == Type.USER) {
      LOG.info(
          "Classified error as USER error based on missing topic. Query ID: {} Exception: {}",
          queryId,
          e);
    }

    return type;
  }

  public  MissingTopicClassifier(final String queryId);

}