Class GetLastProducedTimeAction

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

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

    • GetLastProducedTimeAction

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

    • getLastProducedTime

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