Reseting to previous commit 2deb284998f46cebe56186d27dcc075236ccd8fa, code progress now in branch kafka_test