docs: private void start() {
  		if (independent) {
  			logger.info("KAFKA 启动模式[independent]");
  			new Thread(new Runnable() {
  				@Override
  				public void run() {
  					registerKafkaSubscriber();
  				}
  			}).start();
  		} else {
  			registerKafkaSubscriber();
  		}
  	}