nearly working embedded kafka unit test