MicahRam commented on pull request #8181:
URL: https://github.com/apache/kafka/pull/8181#issuecomment-691360304
@mjsax that sounds like it will work for the majority of the use cases I've
come across. One thing thats not clear to me is how kstream operations that are
down stream of a process would handle headers. For instance:
```
from("in")
.transform(ForwardsFromTransformAndPunctuate::new)
.transform(ModifyHeadersInTransform::new) // Should this type check the
context before accessing headers?
.setHeaders() // will this exception when processing driven by punctuate
reaches here?
.to("out")
```
----------------------------------------------------------------
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
