Remove global kafka instance from tests

Instead each test launches its own kafka/zookeeper
This needs to be volatile otherwise there's no guarantee an update on one thread will be visible to another. Probably just use AtomicBoolean?