in src/main/java/org/apache/doris/kafka/connector/service/RestService.java [266:282]
private static String parseResponse(HttpURLConnection connection, Logger logger)
throws IOException {
if (connection.getResponseCode() != HttpStatus.SC_OK) {
logger.warn(
"Failed to get response from Doris {}, http code is {}",
connection.getURL(),
connection.getResponseCode());
throw new IOException("Failed to get response from Doris");
}
StringBuilder result = new StringBuilder();
try (Scanner scanner = new Scanner(connection.getInputStream(), "utf-8")) {
while (scanner.hasNext()) {
result.append(scanner.next());
}
return result.toString();
}
}