code is now here: https://github.com/aerogear/kafka-cdi