use a group
simplifying refactoring to kafka persist - NOTE neither test is passing in this commit
merge - tests still aren't passing
merge