loicgreffier commented on PR #17960:
URL: https://github.com/apache/kafka/pull/17960#issuecomment-2621402537
From my tests, the following topology:
```java
builder
.stream()
.groupByKey()
.windowedBy(...) // Does not really matter. NPE thrown windowing or not
.aggregate(...)
.mapValues(value -> throw new RuntimeException(...))
```
Is not throwing a NPE anymore (compared to the previous PR
https://github.com/apache/kafka/pull/16684), since we're using `sourceRawKey`
and `sourceRawValue` in `ProcessorNode` instead of `rawRecord().key` and
`rawRecord().value`.
However, `sourceRawKey` and `sourceRawValue` are lost. Going to open a new
PR to address this case.
--
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]
