in src/main/java/com/google/cloud/run/kafkascaler/RequestResponseHandler.java [37:48]
static ImmutableMap<String, String> getRequestHeaderMap(HttpExchange exchange) {
if (exchange == null || exchange.getRequestHeaders() == null) {
return ImmutableMap.of();
}
Map<String, String> headers = new HashMap<>();
for (Map.Entry<String, List<String>> entry : exchange.getRequestHeaders().entrySet()) {
headers.put(entry.getKey(), String.join(",", entry.getValue()));
}
return ImmutableMap.copyOf(headers);
}