[ https://issues.apache.org/jira/browse/KAFKA-16585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17840907#comment-17840907 ]
Matthias J. Sax commented on KAFKA-16585: ----------------------------------------- {quote}I can use the regular Processor, but as I understand it add some overhead comparing with FixedKeyProcessor {quote} Where did you get this? The Processor itself does not have overhead. – The only think that could happen downstream is, that a unnecessary repartition step could be inserted. We are tackling this via [https://cwiki.apache.org/confluence/display/KAFKA/KIP-759%3A+Unneeded+repartition+canceling] {quote}{color:#172b4d}Really, I think FixedKeyProcessor do not need to be "ensure that the key is not changed". IMHO there is enough to have a key from the same partition. So, if you will provide the way to generate the {color}*FixedKeyRecord*{color:#172b4d} from any local store it will be enough.{color} {quote} {color:#172b4d}Well, technically yes, but there is no simply way to enforce/check this... We would need to serialize the provided key, pipe it through the Partitioner, and compare the computed partition. Or is there some other way to do this? – This would be quite expensive to do.{color} {color:#172b4d}If you feel strong about all this, feel free to do a POC PR and write a KIP about it, and we can take it from there. I don't see a simple way to do it, and I believe that using a regular Processor is the right way to go (especially with KIP-759 on the horizon). {color} > No way to forward message from punctuation method in the FixedKeyProcessor > -------------------------------------------------------------------------- > > Key: KAFKA-16585 > URL: https://issues.apache.org/jira/browse/KAFKA-16585 > Project: Kafka > Issue Type: Bug > Components: streams > Affects Versions: 3.6.2 > Reporter: Stanislav Spiridonov > Priority: Major > > The FixedKeyProcessorContext can forward only FixedKeyRecord. This class > doesn't have a public constructor and can be created based on existing > records. But such record usually is absent in the punctuation method. -- This message was sent by Atlassian Jira (v8.20.10#820010)