The java consumer API of kafka is tedious. This is an easy-to-use JDBC for kafka. - View it on GitHub