def setup(self, settings):
        if self.schema == "NONE":
            raise NotImplementedError("Please specify a schema for the kafka monitor")
Setup the handler
dataset/ETHPy150Open istresearch/scrapy-cluster/kafka-monitor/plugins/base_handler.py/BaseHandler.setup