From 7a688f5b34c952aa8da2d981f73805458a0110d9 Mon Sep 17 00:00:00 2001
From: James Kleeh <james.kleeh@gmail.com>
Date: Fri, 15 May 2020 11:54:02 -0400
Subject: [PATCH] Retrieve kafka configuration with raw string convention.
 Fixes micronaut-projects/micronaut-core#3210 (#130)

---
 .../configuration/kafka/config/KafkaDefaultConfiguration.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/kafka/src/main/java/io/micronaut/configuration/kafka/config/KafkaDefaultConfiguration.java b/kafka/src/main/java/io/micronaut/configuration/kafka/config/KafkaDefaultConfiguration.java
index 7adc971be..090103c09 100644
--- a/kafka/src/main/java/io/micronaut/configuration/kafka/config/KafkaDefaultConfiguration.java
+++ b/kafka/src/main/java/io/micronaut/configuration/kafka/config/KafkaDefaultConfiguration.java
@@ -19,6 +19,7 @@
 import io.micronaut.context.annotation.Requires;
 import io.micronaut.context.env.Environment;
 import io.micronaut.core.convert.ConversionService;
+import io.micronaut.core.naming.conventions.StringConvention;
 import org.apache.kafka.clients.consumer.ConsumerConfig;
 
 import java.time.Duration;
@@ -80,7 +81,7 @@ public void setHealthTimeout(Duration healthTimeout) {
     }
 
     private static Properties resolveDefaultConfiguration(Environment environment) {
-        Map<String, Object> values = environment.containsProperties(PREFIX) ? environment.getProperties(PREFIX) : Collections.emptyMap();
+        Map<String, Object> values = environment.containsProperties(PREFIX) ? environment.getProperties(PREFIX, StringConvention.RAW) : Collections.emptyMap();
         Properties properties = new Properties();
         values.entrySet().stream().filter(entry -> {
             String key = entry.getKey();