如何将spring cloud任务java jar注册到spring数据流kubernetes中

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-dataflow-client</artifactId>
</dependency>

spring.cloud.dataflow.client.server-uri=http://<dataflow-server>:<port>

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.dataflow.rest.client.DataFlowTemplate;
import org.springframework.cloud.dataflow.rest.client.TaskOperations;
import org.springframework.cloud.dataflow.rest.resource.TaskDefinitionResource;

@SpringBootApplication
public class TaskRegistrationApplication {

    public static void main(String[] args) {
        SpringApplication.run(TaskRegistrationApplication.class, args);
        registerTask();
    }

    private static void registerTask() {
        DataFlowTemplate dataFlowTemplate = new DataFlowTemplate("<dataflow-server>:<port>");
        TaskOperations taskOperations = dataFlowTemplate.taskOperations();
        TaskDefinitionResource taskDefinitionResource = new TaskDefinitionResource("task-name", "task-jar-location");
        taskOperations.createTaskDefinition(taskDefinitionResource);
    }
}

apiVersion: batch/v1
kind: Job
metadata:
  name: task-job
spec:
  template:
    spec:
      containers:
      - name: task-container
        image: <task-image>
        command: ["java", "-jar", "/path/to/task.jar"]
      restartPolicy: Never

kubectl apply -f task.yaml