回忆

全网都没找到好的解决方法，建议升级kafka版本，可以在新的版本中已经修复了。

知道你还会来。

又来学习了。

https://www.orchome.com/10235

我发现在使用job.getStatus()进行轮询时，即使在使用kubectl从命令提示符检查时，状态发生变化，JobStatus也不会被更新。

为了解决这个问题，我重新加载job处理程序。

client.extensions().jobs()
                   .inNamespace(myJob.getMetadata().getNamespace())
                   .withName(myJob.getMetadata().getName())
                   .get();

我检查job状态的循环是这样的。

KubernetesClient client = new DefaultKubernetesClient(config);
Job myJob = client.extensions().jobs()
                  .load(new FileInputStream("/path/x.yaml"))
                  .create();
boolean jobActive = true;
while(jobActive){
    myJob = client.extensions().jobs()
            .inNamespace(myJob.getMetadata().getNamespace())
            .withName(myJob.getMetadata().getName())
            .get();
    JobStatus myJobStatus = myJob.getStatus();
    System.out.println("==================");
    System.out.println(myJobStatus.toString());

    if(myJob.getStatus().getActive()==null){
        jobActive = false;
    }
    else {
        System.out.println(myJob.getStatus().getActive());
        System.out.println("Sleeping for a minute before polling again!!");
        Thread.sleep(60000);
    }
}

System.out.println(myJob.getStatus().toString());

希望对你有帮助