I wrote a low-level interface for this a while back: http://www.smalltalkhub.com/#!/~cbc/KAFKAClient (it does skip zookeeper, though). And I've used it for reading from Kafka, but have not verified writing to it - and didn't finish that part (didn't need it). I did need additional ByteArray at:put: and at: methods - for 32 and 64 bit access (and 8 bit signed access as well) - which where mostly added to Squeak (where I used this from). Enjoy, -cbc On Mon, Dec 28, 2015 at 9:19 AM, Frank Shearar <frank.shearar@gmail.com> wrote:
On 27 December 2015 at 16:11, Robert Withers <robert.w.withers@gmail.com> wrote:
This would be awesome in Pharo:
https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Proto... .
Since we cannot yet call JARs, implementing the wire protocol and API proxies would really be huge from an enterprise pharo standpoint. If other folks are interested in working on this, I could help out.
Having a Kafka client in Pharo would indeed be awesome. But who cares about calling JARs? It's a wire protocol; write a client against that and you're done.
frank