From f68c71cab1208f7d4e1f008f375a6d7572bb1bcd Mon Sep 17 00:00:00 2001 From: Emily Casey Date: Fri, 15 May 2020 16:50:39 -0400 Subject: [PATCH] fix kafka kind Signed-off-by: Emily Casey --- .../cloud/bindings/boot/KafkaBindingsPropertiesProcessor.java | 2 +- .../bindings/boot/KafkaBindingsPropertiesProcessorTest.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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);