fix(test): making the kafka test pass

Change-Id: I322a9c4235dd67bfd821abaf55e23f7dda66cfdf
Merge pull request #702 from rtoma/kafka-test

fix(test): making the kafka test pass