code: def _feed_to_kafka(self, json_item):
          
          @MethodTimer.timeout(self.settings['KAFKA_FEED_TIMEOUT'], False)
          def _feed(json_item):
              try:
                  self.logger.debug("Sending json to kafka at " +
                                    str(self.settings['KAFKA_PRODUCER_TOPIC']))
                  future = self.producer.send(self.settings['KAFKA_PRODUCER_TOPIC'],
                                     json_item)
                  future.add_callback(self._kafka_success)
                  future.add_errback(self._kafka_failure)
  
                  self.producer.flush()
  
                  return True
  
              except Exception as e:
                  self.logger.error("Lost connection to Kafka")
                  self._spawn_kafka_connection_thread()
                  return False
  
          return _feed(json_item)
docs: Sends a request to Kafka
  
          :param json_item: The json item to send
          :returns: A boolean indicating whther the data was sent successfully or not