Skip to content

Commit

Permalink
[MGDSTRM-9160] Process authentication and end-points as blocking
Browse files Browse the repository at this point in the history
Avoids complexity of running various subtasks of some operations on a
worker thread.
  • Loading branch information
MikeEdgar committed Jul 29, 2022
1 parent 7455cae commit 40fd775
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -37,6 +37,7 @@
import java.util.stream.Collectors;

@Path("/api/v1")
@Blocking
public class RestOperations implements OperationsHandler {

private static final Logger log = Logger.getLogger(RestOperations.class);
Expand Down Expand Up @@ -128,7 +129,6 @@ public CompletionStage<Response> listTopics(String filter, Types.DeprecatedPageR
.thenApply(topicList -> Response.ok().entity(topicList).build());
}

@Blocking
@Counted("consume_records_requests")
@Timed("consume_records_request_time")
public Response consumeRecords(String topicName,
Expand Down
1 change: 1 addition & 0 deletions kafka-admin/src/main/resources/application.properties
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,7 @@ quarkus.index-dependency.kafka-clients.artifact-id=kafka-clients

# The following properties will be used when adding JWT RBAC provided by quarkus-smallrye-jwt
quarkus.smallrye-jwt.enabled=true
quarkus.smallrye-jwt.blocking-authentication=true
mp.jwt.verify.publickey.location=${kafka.admin.oauth.jwks.endpoint.uri: }
mp.jwt.verify.issuer=${kafka.admin.oauth.valid.issuer.uri: }
smallrye.jwt.client.tls.certificate=${kafka.admin.oauth.trusted.cert:}
Expand Down

0 comments on commit 40fd775

Please sign in to comment.