diff --git a/src/main/java/org/springframework/cloud/bindings/boot/KafkaBindingsPropertiesProcessor.java b/src/main/java/org/springframework/cloud/bindings/boot/KafkaBindingsPropertiesProcessor.java index 343e886..37519ee 100644 --- a/src/main/java/org/springframework/cloud/bindings/boot/KafkaBindingsPropertiesProcessor.java +++ b/src/main/java/org/springframework/cloud/bindings/boot/KafkaBindingsPropertiesProcessor.java @@ -31,7 +31,7 @@ final class KafkaBindingsPropertiesProcessor implements BindingsPropertiesProces /** * The {@link Binding} kind that this processor is interested in: {@value}. **/ - public static final String KIND = "Cassandra"; + public static final String KIND = "Kafka"; @Override public void process(Environment environment, Bindings bindings, Map properties) { diff --git a/src/test/java/org/springframework/cloud/bindings/boot/KafkaBindingsPropertiesProcessorTest.java b/src/test/java/org/springframework/cloud/bindings/boot/KafkaBindingsPropertiesProcessorTest.java index 8691f9a..6d62cd0 100644 --- a/src/test/java/org/springframework/cloud/bindings/boot/KafkaBindingsPropertiesProcessorTest.java +++ b/src/test/java/org/springframework/cloud/bindings/boot/KafkaBindingsPropertiesProcessorTest.java @@ -62,7 +62,7 @@ final class KafkaBindingsPropertiesProcessorTest { @Test @DisplayName("can be disabled") void disabled() { - environment.setProperty("org.springframework.cloud.bindings.boot.cassandra.enable", "false"); + environment.setProperty("org.springframework.cloud.bindings.boot.kafka.enable", "false"); new KafkaBindingsPropertiesProcessor().process(environment, bindings, properties);