code: def _onerror(cls, kmsg, result):
          
          logger.error(
              "{}.Failed: {}[{}]: {}".format(
                  cls.__name__, kmsg.entrypoint, kmsg.uuid, result
              ),
              extra=dict(
                  kmsg=kmsg.dump(),
                  kresult=ResultSchema().dump(result) if result else dict()
              )
          )
          return cls.onerror(kmsg, result)
docs: To execute on execution failure
  
          :param kser.schemas.Message kmsg: Kafka message
          :param kser.result.Result result: Execution result
          :return: Execution result
          :rtype: kser.result.Result