in src/main/java/com/google/cloud/run/kafkascaler/RequestResponseHandler.java [73:83]
static void sendSuccessResponse(HttpExchange exchange) {
String response = "OK: Successfully refreshed scaling recommendation.";
try (OutputStream os = exchange.getResponseBody()) {
exchange.sendResponseHeaders(200, Utf8.encodedLength(response));
os.write(response.getBytes(UTF_8));
} catch (IOException io) {
// Processing has already completed. Just log the error.
logger.atWarning().withCause(io).log("Failed while writing successful response");
}
}