[DISCUSS] KIP-28 - Add a transform client for data processing

2015-08-19 Thread Yan Fang
Hi Guozhang, Thank you for writing the KIP-28 up. (Hope this is the right thread for me to post some comments. :) I still have some confusing about the implementation of the Processor: 1. why do we maintain a separate consumer and producer for each worker thread? — from my understanding,

Re: [DISCUSS] KIP-28 - Add a transform client for data processing

2015-08-19 Thread Guozhang Wang
Hello Yan, Thanks for the feedback, replies inlined. Guozhang On Wed, Aug 19, 2015 at 8:22 AM, Yan Fang yanfang...@me.com wrote: Hi Guozhang, Thank you for writing the KIP-28 up. (Hope this is the right thread for me to post some comments. :) I still have some confusing about the