def initial_setup(self): """set up consumer""" try: self.create_kafka_consumer() except Exception as e: LOGGER.critical( "Could not create consumer with {0}".format(e), exc_info=e) LOGGER.critical("Exiting due to inability to create consumer") sys.exit(0)
