vvcephei commented on a change in pull request #9148:
URL: https://github.com/apache/kafka/pull/9148#discussion_r468872295
##########
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java
##########
@@ -532,14 +539,14 @@ public final void addStateStore(final StoreBuilder<?>
storeBuilder,
nodeGroups = null;
}
- public final <KIn, VIn, KOut, VOut> void addGlobalStore(final
StoreBuilder<?> storeBuilder,
+ public final <KIn, VIn> void addGlobalStore(final StoreBuilder<?>
storeBuilder,
Review comment:
I didn't realize it in the last PR, but the output types for the
`stateUpdate` processor is always `Void, Void` (ie., you can't forward
anything, since the only function of that processor is to update the store
itself). So we don't need the parameters; I've just expanded them to `Void,
Void` below.
----------------------------------------------------------------
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
