Fixes #16477. Quarkus Kafka client uses camelCase binding files.

quarkusio · Apr 13, 2021 · 84bab15 · 84bab15
1 parent bff037b
commit 84bab15
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...a-client/runtime/src/main/java/io/quarkus/kafka/client/runtime/KafkaBindingConverter.java b/...a-client/runtime/src/main/java/io/quarkus/kafka/client/runtime/KafkaBindingConverter.java
@@ -21,20 +21,20 @@ public Optional<ServiceBindingConfigSource> convert(List<ServiceBinding> service
         Map<String, String> properties = new HashMap<>();
         ServiceBinding binding = matchingByType.get();
 
-        String bootstrapServers = binding.getProperties().get("bootstrapservers");
+        String bootstrapServers = binding.getProperties().get("bootstrapServers");
         if (bootstrapServers == null) {
             bootstrapServers = binding.getProperties().get("bootstrap-servers");
         }
         if (bootstrapServers != null) {
             properties.put("kafka.bootstrap.servers", bootstrapServers);
         }
 
-        String securityProtocol = binding.getProperties().get("securityprotocol");
+        String securityProtocol = binding.getProperties().get("securityProtocol");
         if (securityProtocol != null) {
             properties.put("kafka.security.protocol", securityProtocol);
         }
 
-        String saslMechanism = binding.getProperties().get("saslmechanism");
+        String saslMechanism = binding.getProperties().get("saslMechanism");
         if (saslMechanism != null) {
             properties.put("kafka.sasl.mechanism", saslMechanism);
         }