Записывает ли Jetty пользовательский код статуса http? - PullRequest
Новая
       63

Записывает ли Jetty пользовательский код статуса http?

0 голосов
/ 07 мая 2018

Я пытаюсь разработать остальные API для своего сервиса, в которых я устанавливаю собственный код статуса http в зависимости от ошибки авторизации.Но когда я проверяю это, используя curl, я получаю 404 вместо 403. Я озадачен тем, что может быть причиной этого?Пожалуйста помоги.

Это то, что я вижу из вывода скручивания или пользовательского интерфейса: 

root@ubuntu:~# curl -X GET http://localhost:8082/mr/v1/topic/bhakk -v
Note: Unnecessary use of -X or --request, GET is already inferred.
*   Trying 127.0.0.1...
* Connected to localhost (127.0.0.1) port 8082 (#0)
> GET /mr/v1/topic/bhakk HTTP/1.1
> Host: localhost:8082
> User-Agent: curl/7.47.0
> Accept: */*
>
< HTTP/1.1 404 Not Found
< Date: Mon, 07 May 2018 22:00:10 GMT
< Exception: serviceBlockedException
< Content-Type: application/vnd.kafka.v1+json
< Content-Length: 83
< Server: Jetty(9.2.z-SNAPSHOT)
<
* Connection #0 to host localhost left intact
{"error_code":40301,"message":"This service does not have access to the resource."}

Вот код: 

    public Collection<String> list(@HeaderParam("x-nssvc-serviceid") String serviceID) {
        Date now = new java.util.Date();
        if (! ctx.getSecurityRestrictions().isServiceAllowed(uri, httpHeaders, "Describe", "Cluster", "kafka-cluster"))
          throw Errors.serviceBlockedException(ctx,httpServletResponse);

        List<String> topicsCopy = new ArrayList<String>(topics);
        for (Iterator<String> iterator = topicsCopy.iterator(); iterator.hasNext();) {
          String topic = iterator.next();
          if (! ctx.getSecurityRestrictions().hasAccess (serviceId, "Describe", "Topic", topic)) {
            iterator.remove();
          }
        }

        return topicsCopy;
      }

    public static RestException serviceBlockedException(Context ctx,HttpServletResponse httpServletResponse) {
        httpServletResponse.setHeader("Exception","serviceBlockedException");
        httpServletResponse.setStatus(Status.FORBIDDEN.getStatusCode()); <----// here i am setting status code.
        return new RestNotFoundException(SERVICE_ID_BLOCKED_MESSAGE, SERVICE_ID_BLOCKED_ERROR_CODE);
      }

1 Ответ

0 голосов
/ 07 мая 2018

Кафка устанавливает статус Response 404 в RestNotFoundException

См .: https://github.com/confluentinc/rest-utils/blob/master/core/src/main/java/io/confluent/rest/exceptions/RestNotFoundException.java

...