<SYSTEM_TASK:>
Solve the following problem using Python, implementing the functions described below, one line at a time
<END_TASK>
<USER_TASK:>
Description:
 def _feed_to_kafka(self, json_item):
 """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 """

        @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)