dnishimura commented on a change in pull request #1016: SAMZA-2179: Move the
StartpointVisitor abstraction to SystemAdmin interface.
URL: https://github.com/apache/samza/pull/1016#discussion_r279829110
##########
File path: samza-api/src/main/java/org/apache/samza/system/SystemAdmin.java
##########
@@ -164,4 +165,10 @@ default void deleteMessages(Map<SystemStreamPartition,
String> offsets) {
throw new UnsupportedOperationException();
}
+ /**
+ * Builds and returns the {@link StartpointVisitor} for a system.
+ */
+ default StartpointVisitor getStartpointVisitor() {
Review comment:
Are you going to integrate this with the `OffsetManager` in a follow PR? I
don't see it being used in the current PR.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
