Hello, I wish to introduce a minor addition present in RecordContext (a public facing API). This addition works to both provide the user with more information regarding the processing state of the partition, but also help resolve a bug which Kafka is currently experiencing. Here is the KIP Link: https://cwiki.apache.org/confluence/display/KAFKA/KIP-472%3A+%5BSTREAMS%5D+Add+partition+time+field+to+RecordContext
Cheers, Richard Yu
