Class ListAllLastProducedTimesAction

java.lang.Object
io.confluent.kafkarest.resources.v3.ListAllLastProducedTimesAction

@Path("/v3/clusters/{clusterId}/topics/-/last-produced-time") public final class ListAllLastProducedTimesAction extends Object
  • Constructor Details

    • ListAllLastProducedTimesAction

      @Inject public ListAllLastProducedTimesAction(jakarta.inject.Provider<LastProducedTimeManager> lastProducedTimeManager, io.confluent.kafkarest.response.UrlFactory urlFactory)
  • Method Details

    • listAllLastProducedTimes

      @GET @Produces("application/json") @PerformanceMetric("v3.topics.last-produced-time.list-all") public void listAllLastProducedTimes(@Suspended jakarta.ws.rs.container.AsyncResponse asyncResponse, @PathParam("clusterId") String clusterId)