vvcephei commented on a change in pull request #11676:
URL: https://github.com/apache/kafka/pull/11676#discussion_r793214036
##########
File path:
streams/src/main/java/org/apache/kafka/streams/processor/StateStore.java
##########
@@ -152,4 +153,11 @@ default void init(final StateStoreContext context, final
StateStore root) {
// If a store doesn't implement a query handler, then all queries are
unknown.
return QueryResult.forUnknownQueryType(query, this);
}
+
+ /**
+ * This state store's position
+ */
+ default Position getPosition() {
+ throw new UnsupportedOperationException("Not implemented");
Review comment:
Note: this was added in another PR (not sure why it was also in this
one). By adding this to the StateStore interface @vpapavas was able to
dramatically simplify the change-logging store layers. However, it may be
possible to avoid this as part of the same follow-on revision we discussed
above.
--
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]
