Guozhang Wang created KAFKA-3505:
------------------------------------
Summary: Set curRecord in punctuate() functions
Key: KAFKA-3505
URL: https://issues.apache.org/jira/browse/KAFKA-3505
Project: Kafka
Issue Type: Sub-task
Reporter: Guozhang Wang
Fix For: 0.10.1.0
Punctuate() function in processor and transformer needs to be handled a bit
differently from process(), since it can generate new records to pass through
the topology from anywhere of the topology, whereas for the latter case a
record is always polled from Kafka and passed via the source processors.
Today because we do not set the curRecord correctly, calls to timestamp() /
topic() / etc would actually trigger a KafkaStreamsException.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
