add test via kafka
Merge branch 'newdbdesign' of https://github.com/xumiao/pymonk into newdbdesign