KAFKA-16505: Add source raw bytes in processorContex#17960
KAFKA-16505: Add source raw bytes in processorContex#17960Dabz wants to merge 1 commit intoapache:trunkfrom
Conversation
7cd809b to
33a294b
Compare
132aaab to
82d61c7
Compare
|
From my tests, the following topology: 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 #16684), since we're using However, |
Co-authored-by: loicgreffier <loic.greffier@michelin.com>
9769124 to
207c365
Compare
|
This PR is being marked as stale since it has not had any activity in 90 days. If you If you are having difficulty finding a reviewer, please reach out on the [mailing list](https://kafka.apache.org/contact). If this PR is no longer valid or desired, please feel free to close it. If no activity occurs in the next 30 days, it will be automatically closed. |
|
Superseded by #18739 |
Pull request to implement KIP-1034, it adds the records source byte in the processor context
Committer Checklist (excluded from commit message)