在Kafka源码的streams/examples包中有相关的例子。
http://orchome.com/335