Fix case of Kafka ServiceBinging properties

Fixes quarkusio#16477 (cherry picked from commit fadc477)
gsmet · Apr 14, 2021 · 8c439b5 · 8c439b5
1 parent 7650bc2
commit 8c439b5
Show file tree

Hide file tree

Showing 2 changed files 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);
         }

diff --git a/...ources/k8s-sb/some-kafka/bootstrapservers → ...ources/k8s-sb/some-kafka/bootstrapServers b/...ources/k8s-sb/some-kafka/bootstrapservers → ...ources/k8s-sb/some-kafka/bootstrapServers