code: def send(self, topic, kmsg, timeout=60):
          
          result = Result(uuid=kmsg.uuid)
          try:
              self.client.produce(
                  topic, self._onmessage(kmsg).dumps().encode("UTF-8")
              )
              result.stdout = "Message {}[{}] sent".format(
                  kmsg.entrypoint, kmsg.uuid
              )
              self.client.flush()
  
          except Exception as exc:
              result = Result.from_exception(exc, kmsg.uuid)
  
          finally:
              if result.retcode < 300:
                  return self._onsuccess(kmsg=kmsg, result=result)
              else:
                  return self._onerror(kmsg=kmsg, result=result)
docs: Send the message into the given topic
  
          :param str topic: a kafka topic
          :param ksr.transport.Message kmsg: Message to serialize
          :param int timeout: Timeout in seconds (not used in proto producer)
          :return: Execution result
          :rtype: kser.result.Result