def send(self, messages):

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

    return self.write(self.encode_request(messages))
Send a :class:`Message <kafka.message>` or a sequence of `Messages` to the Kafka server.
dataset/ETHPy150Open harelba/tail2kafka/kafka/producer.py/Producer.send