Function UpdateSubscriptionJobV2

api/handler/v2/job.go:1236–1239

@Id CreateOrUpdateSubscriptionJobV2 @Description update subscription job. @Tags job @Accept application/json @Security ApiKeyAuth @Param subscription_job_config body models.CreateOrUpdateMysqlToKafkaJobParamV2 true "subscription job config" @Success 200 {object} models.CreateOrUpdateMysqlToKafkaJobR

(c echo.Context)

// @Success 200 {object} models.CreateOrUpdateMysqlToKafkaJobRespV2
// @Router /v2/job/subscription/update [post]
func UpdateSubscriptionJobV2(c echo.Context) error {
	logger := handler.NewLogger().Named("UpdateSubscriptionJobV2")
	return createOrUpdateDBToKafkaJob(c, logger, DtleJobTypeSubscription, false)
}

func createOrUpdateDBToKafkaJob(c echo.Context, logger g.LoggerType, jobType DtleJobType, create bool) error {