LastProducedTimeManager (ce-kafka-rest-extensions 8.2.0-ce API)

public interface LastProducedTimeManager

A service to manage LastProducedTime.

Method Summary

Modifier and Type

Method

Description

CompletableFuture<LastProducedTime>

getLastProducedTime(String clusterId, String topicName)

Returns the lastProducedTime for the last message produced to a given clusterId and topicName.

CompletableFuture<List<LastProducedTime>>

listLastProducedTimes(String clusterId)

Returns list of lastProducedTime for the last message produced for each topic in a given clusterId.

Method Details
- getLastProducedTime
  
  CompletableFuture<LastProducedTime> getLastProducedTime(String clusterId, String topicName)
  
  Returns the lastProducedTime for the last message produced to a given clusterId and topicName.
- listLastProducedTimes
  
  CompletableFuture<List<LastProducedTime>> listLastProducedTimes(String clusterId)
  
  Returns list of lastProducedTime for the last message produced for each topic in a given clusterId.