@Override
  public void start() throws Exception {
    try {
      server.startServer(config, handlers, null, authenticator, null);
    } catch (IOException e) {
      throw new RuntimeException("Exception while starting server", e);
    }

    LOGGER.info(
        "Start MQTT Extractor successfully, listening on ip {}, port {}",
        config.getProperty(BrokerConstants.HOST_PROPERTY_NAME),
        config.getProperty(BrokerConstants.PORT_PROPERTY_NAME));
  }
MQTTExtractor is an external Extractor that uses the MQTT protocol to receive data. It starts an
MQTT broker and listens for incoming messages, which are then processed and passed to the pending
queue.
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/mqtt/MQTTExtractor.java