sebastienviale commented on PR #18739: URL: https://github.com/apache/kafka/pull/18739#issuecomment-2729806425
As @loicgreffier said, it is mentioned in the KIP that the raw record value: "If available, contains the value of the input message that triggered the sub-topology, null if triggered by punctuate" Which seems to correspond to solution (a). It also seems logical to store in the raw record the last record before the exception occurs. -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
