[jira] [Commented] (KAFKA-13699) ProcessorContext does not expose Stream Time
[ https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505386#comment-17505386 ] Guozhang Wang commented on KAFKA-13699: --- I agree with [~mimaison], that we would only be able to fix forward in 3.2.0+. > ProcessorContext does not expose Stream Time > > > Key: KAFKA-13699 > URL: https://issues.apache.org/jira/browse/KAFKA-13699 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 2.7.0 >Reporter: Shay Lin >Assignee: Matthias J. Sax >Priority: Major > Labels: newbie > > As a KS developer, I would like to leverage > [KIP-622|https://cwiki.apache.org/confluence/display/KAFKA/KIP-622%3A+Add+currentSystemTimeMs+and+currentStreamTimeMs+to+ProcessorContext] > and access stream time in Processor Context. > _(Updated)_ > However, the methods currentStreamTimeMs or currentSystemTimeMs is missing > from for KStreams 3.0+. > Checked with [~mjsax] , the methods are absent from the Processor API , i.e. > * org.apache.kafka.streams.processor.api.ProcessorContext -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (KAFKA-13699) ProcessorContext does not expose Stream Time
[ https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503493#comment-17503493 ] Mickael Maison commented on KAFKA-13699: Even if it was voted and partly landed in 3.0.0, I think we should only the missing APIs in 3.2.0. > ProcessorContext does not expose Stream Time > > > Key: KAFKA-13699 > URL: https://issues.apache.org/jira/browse/KAFKA-13699 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 2.7.0 >Reporter: Shay Lin >Priority: Major > Labels: newbie > > As a KS developer, I would like to leverage > [KIP-622|https://cwiki.apache.org/confluence/display/KAFKA/KIP-622%3A+Add+currentSystemTimeMs+and+currentStreamTimeMs+to+ProcessorContext] > and access stream time in Processor Context. > _(Updated)_ > However, the methods currentStreamTimeMs or currentSystemTimeMs is missing > from for KStreams 3.0+. > Checked with [~mjsax] , the methods are absent from the Processor API , i.e. > * org.apache.kafka.streams.processor.api.ProcessorContext -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (KAFKA-13699) ProcessorContext does not expose Stream Time
[ https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503214#comment-17503214 ] Matthias J. Sax commented on KAFKA-13699: - Seems the only question is, if we need to update the KIP? And if we can only fix forward in 3.2.0 (or if we can back-port to `3.0.1` and `3.1.1` ? \cc [~mimaison] [~guozhang] WDYT? `3.0.1` is already on it's way... > ProcessorContext does not expose Stream Time > > > Key: KAFKA-13699 > URL: https://issues.apache.org/jira/browse/KAFKA-13699 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 2.7.0 >Reporter: Shay Lin >Priority: Major > Labels: newbie > > As a KS developer, I would like to leverage > [KIP-622|https://cwiki.apache.org/confluence/display/KAFKA/KIP-622%3A+Add+currentSystemTimeMs+and+currentStreamTimeMs+to+ProcessorContext] > and access stream time in Processor Context. > _(Updated)_ > However, the methods currentStreamTimeMs or currentSystemTimeMs is missing > from for KStreams 3.0+. > Checked with [~mjsax] , the methods are absent from the Processor API , i.e. > * org.apache.kafka.streams.processor.api.ProcessorContext -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (KAFKA-13699) ProcessorContext does not expose Stream Time
[ https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17501571#comment-17501571 ] Shay Lin commented on KAFKA-13699: -- Hi team [~guozhang] [~mjsax] yes, as Matthias mentioned, the methods are missing in `.api.ProcessorContext` API. (Matthias and I connected offline and discussed it wouldn't be possible to patch backwards in 2.7.0. ) > ProcessorContext does not expose Stream Time > > > Key: KAFKA-13699 > URL: https://issues.apache.org/jira/browse/KAFKA-13699 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 2.7.0 >Reporter: Shay Lin >Priority: Major > > As a KS developer, I would like to leverage > [KIP-622|https://cwiki.apache.org/confluence/display/KAFKA/KIP-622%3A+Add+currentSystemTimeMs+and+currentStreamTimeMs+to+ProcessorContext] > and access stream time in Processor Context. > However, the methods currentStreamTimeMs or currentSystemTimeMs is missing > from for KStreams 2.7.0 (Java). > Checked with [~mjsax] , the methods are absent from both the Processor API > and old version, i.e. > * org.apache.kafka.streams.processor.api.ProcessorContext > * org.apache.kafka.streams.processor.ProcessorContext -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (KAFKA-13699) ProcessorContext does not expose Stream Time
[ https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499691#comment-17499691 ] Matthias J. Sax commented on KAFKA-13699: - That's my understanding, too. Seems we missed to add both to the new `.api.ProcessorContext` API, as both KIPs kinda overlapped. Not sure if we could fix this in 3.0 and 3.1 as KIP-622 originally landed in 3.0, or if we can only fix forward in 3.2? > ProcessorContext does not expose Stream Time > > > Key: KAFKA-13699 > URL: https://issues.apache.org/jira/browse/KAFKA-13699 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 2.7.0 >Reporter: Shay Lin >Priority: Major > > As a KS developer, I would like to leverage > [KIP-622|https://cwiki.apache.org/confluence/display/KAFKA/KIP-622%3A+Add+currentSystemTimeMs+and+currentStreamTimeMs+to+ProcessorContext] > and access stream time in Processor Context. > However, the methods currentStreamTimeMs or currentSystemTimeMs is missing > from for KStreams 2.7.0 (Java). > Checked with [~mjsax] , the methods are absent from both the Processor API > and old version, i.e. > * org.apache.kafka.streams.processor.api.ProcessorContext > * org.apache.kafka.streams.processor.ProcessorContext -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (KAFKA-13699) ProcessorContext does not expose Stream Time
[ https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499683#comment-17499683 ] Guozhang Wang commented on KAFKA-13699: --- Hi [~lqxshay] thanks for filing the ticket. Just to clarify I think the function did exist in the deprecated old API: ``` org.apache.kafka.streams.processor.ProcessorContext ``` They are not in the new API: ``` org.apache.kafka.streams.processor.api.ProcessorContext ``` Is that right? > ProcessorContext does not expose Stream Time > > > Key: KAFKA-13699 > URL: https://issues.apache.org/jira/browse/KAFKA-13699 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 2.7.0 >Reporter: Shay Lin >Priority: Major > > As a KS developer, I would like to leverage > [KIP-622|https://cwiki.apache.org/confluence/display/KAFKA/KIP-622%3A+Add+currentSystemTimeMs+and+currentStreamTimeMs+to+ProcessorContext] > and access stream time in Processor Context. > However, the methods currentStreamTimeMs or currentSystemTimeMs is missing > from for KStreams 2.7.0 (Java). > Checked with [~mjsax] , the methods are absent from both the Processor API > and old version, i.e. > * org.apache.kafka.streams.processor.api.ProcessorContext > * org.apache.kafka.streams.processor.ProcessorContext -- This message was sent by Atlassian Jira (v8.20.1#820001)
