jeqo commented on a change in pull request #11412:
URL: https://github.com/apache/kafka/pull/11412#discussion_r744982312
##########
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggregate.java
##########
@@ -142,7 +142,7 @@ public void process(final Record<KIn, VIn> record) {
private TimestampedKeyValueStore<KIn, VAgg> store;
@Override
- public void init(final
org.apache.kafka.streams.processor.ProcessorContext context) {
+ public void init(final ProcessorContext<?, ?> context) {
Review comment:
Interesting. As far as I can see the value getters do not forward, so
retricting the types could be an option.
At the moment though, these value getters are initialized as part of the
processor itself, and changing this types would break things.
Do you think we should consider redesign this internal api inthe future as
well?
--
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: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
