provide kafka implementation
provide cluster selector implementation