NOTE: This project has been moved into storm-kafka in storm-contrib - View it on GitHub