Hi everyone, Thank you for constructive feedback on KIP-121, KStream.peek(ForeachAction<K, V>) ; it seems like it is time to call a vote which I hope will pass easily :)
https://cwiki.apache.org/confluence/display/KAFKA/KIP-121%3A+Add+KStream+peek+method I believe the PR attached is already in good shape to consider merging: https://github.com/apache/kafka/pull/2493 Thanks! Steven
signature.asc
Description: Message signed with OpenPGP using GPGMail
