mcvsubbu commented on code in PR #9289:
URL: https://github.com/apache/pinot/pull/9289#discussion_r956620496
##########
pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/PinotRealtimeTableResource.java:
##########
@@ -78,13 +79,21 @@ public Response pauseConsumption(
@Path("/tables/{tableName}/resumeConsumption")
@Produces(MediaType.APPLICATION_JSON)
@ApiOperation(value = "Resume consumption of a realtime table",
- notes = "Resume the consumption for a realtime table")
+ notes = "Resume the consumption for a realtime table. If offset criteria
is not provided, consumption continues "
+ + "based on the offsets in segment ZK metadata")
public Response resumeConsumption(
- @ApiParam(value = "Name of the table", required = true)
@PathParam("tableName") String tableName) {
+ @ApiParam(value = "Name of the table", required = true)
@PathParam("tableName") String tableName,
+ @ApiParam(value = "smallest | largest") @QueryParam("offsetCriteria")
String offsetCriteria) {
Review Comment:
Instead of `offsetCriteria`, can we call it `consumeFrom`? We can translate
it to whatever we want internally.
And the possible values can be `forceEarliest`, `forceLatest`, or `best`
(yes, we need a third value).
`forceEarliest` and `forceLatest` will ignore any previous completed segment
offsets and just do as forced. Pick the earliest or latest offsets and resume
consumption.
The `best` option will attempt to minimize data loss, pick up the first
available event _after_ the last consumed event.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
