.setGracePeriodSeconds(healthCheckConfiguration.getHealthCheckGracePeriod().getSeconds())
.setCommand(CommandInfo.newBuilder()
.setValue("curl -f localhost:$API_PORT/admin/healthcheck")
.build()));
}
<BUG>return TaskUtils.setTargetConfiguration(taskBuilder.build(), UUID.fromString(configName));
</BUG>
}
private static String getBrokerCmd(KafkaSchedulerConfiguration config) {
return Joiner.on(" && ").join(Arrays.asList(

.setGracePeriodSeconds(healthCheckConfiguration.getHealthCheckGracePeriod().getSeconds())
.setCommand(CommandInfo.newBuilder()
.setValue("curl -f localhost:$API_PORT/admin/healthcheck")
.build()));
}
return TaskUtils.setTargetConfiguration(taskBuilder, UUID.fromString(configName)).build();
}
private static String getBrokerCmd(KafkaSchedulerConfiguration config) {
return Joiner.on(" && ").join(Arrays.asList(
