abstract out KafkaIntTestBase, clean up test