diff --git a/extensions/kafka-client/runtime/src/main/java/io/quarkus/kafka/client/runtime/KafkaBindingConverter.java b/extensions/kafka-client/runtime/src/main/java/io/quarkus/kafka/client/runtime/KafkaBindingConverter.java index dbbf3bd4bbec4..f99a5b6a71082 100644 --- a/extensions/kafka-client/runtime/src/main/java/io/quarkus/kafka/client/runtime/KafkaBindingConverter.java +++ b/extensions/kafka-client/runtime/src/main/java/io/quarkus/kafka/client/runtime/KafkaBindingConverter.java @@ -21,7 +21,7 @@ public Optional convert(List service Map 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"); } @@ -42,7 +42,9 @@ public Optional convert(List service String password = binding.getProperties().get("password"); if ("PLAIN".equals(saslMechanism) && (user != null) && (password != null)) { properties.put("kafka.sasl.jaas.config", - String.format("org.apache.kafka.common.security.plain.PlainLoginModule required %s %s", user, password)); + String.format( + "org.apache.kafka.common.security.plain.PlainLoginModule required username='%s' password='%s';", + user, password)); } return Optional.of(new ServiceBindingConfigSource("kafka-k8s-service-binding-source", properties)); diff --git a/integration-tests/kafka-snappy/src/test/resources/k8s-sb/some-kafka/bootstrapServers b/integration-tests/kafka-snappy/src/test/resources/k8s-sb/some-kafka/bootstrapservers similarity index 100% rename from integration-tests/kafka-snappy/src/test/resources/k8s-sb/some-kafka/bootstrapServers rename to integration-tests/kafka-snappy/src/test/resources/k8s-sb/some-kafka/bootstrapservers