def send(self, messages):

    if isinstance(messages, kafka.message.Message):
      messages = [messages]

    return self.write(self.encode_request(messages))
Parse and return text content of infiles
dataset/ETHPy150Open harelba/tail2kafka/kafka/producer.py/Producer.send--crossover with--dataset/ETHPy150Open huntrar/scrape/scrape/utils.py/get_parsed_text