Re: Few questions regarding KAFKA-1928 (reusing common network code in core)

2015-04-07 Thread Jay Kreps
Hey Gwen, Receive and Send are meant to encapsulate the idea of sending or receiving bytes. They are supposed to represent a send or receive that is in progress. The purpose of these interfaces is to allow sends and receives using transferTo when we need to do that on the server side, this require

Re: Few questions regarding KAFKA-1928 (reusing common network code in core)

2015-04-06 Thread Jun Rao
1. The controller -> broker communication doesn't have to be blocking. It just needs to call a callback on completion of a request. We can leave this out for now. It just means that we can't run the inter cluster communication through non-plaintext port until we port this code to the common network

Few questions regarding KAFKA-1928 (reusing common network code in core)

2015-04-06 Thread Gwen Shapira
Hi, I started work on converting core to use common network code and I ran into two questions that hopefully someone can help me with: 1. BlockingChannel - Looks like the inter-broker communication is mostly through blocking channel. There's no client equivalent (i.e client code is all non-blocki