mjsax commented on a change in pull request #9997:
URL: https://github.com/apache/kafka/pull/9997#discussion_r566580568
##########
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##########
@@ -99,6 +100,7 @@
private final InternalProcessorContext processorContext;
private final RecordQueueCreator recordQueueCreator;
+ private StampedRecord record;
Review comment:
We pull this variable out form the method to use it as a "cache" -- if
we fail on send(), we can process the record a second time.
----------------------------------------------------------------
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
