code: def send(self, topic, kmsg):
          
          try:
              self.client.do_request(
                  method="POST", params=dict(format="raw"),
                  path="/topic/{}".format(topic),
                  data=kmsg.MARSHMALLOW_SCHEMA.dump(kmsg)
              )
              result = Result(
                  uuid=kmsg.uuid, stdout="Message sent: {} ({})".format(
                      kmsg.uuid, kmsg.entrypoint
                  )
              )
  
          except Exception as exc:
              result = Result.from_exception(exc, kmsg.uuid)
  
          finally:
              # noinspection PyUnboundLocalVariable
              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
          :return: Execution result
          :rtype: kser.result.Result