Hi everyone,
I wrapped kafka 0.8beta1 client into a jruby class: https://github.com/joekiller/jruby-kafka and then a wrote an input for logstash: https://github.com/joekiller/logstash/tree/kafka8 It's a little rough around the edges still but it does work fine. I'll be enhancing both the logstash side, like making an output, and the jruby-kafka side to create a producer. Either way just putting this out there. -Joe
