Hello users@kafka, I would like to propose a small KIP on the Streams framework that simply adds a KStream#peek implementation.
https://cwiki.apache.org/confluence/display/KAFKA/KIP-121%3A+Add+KStream+peek+method https://issues.apache.org/jira/browse/KAFKA-4720 https://github.com/apache/kafka/pull/2493 Please consider my contribution and hopefully you all like it and agree that it should be merged into 0.10.3 :) If not, be gentle, this is my first KIP! Happy Monday, Steven
signature.asc
Description: Message signed with OpenPGP using GPGMail
