extra commits for using local kafka (not mavenized)