From c22c08e259c9704ffd15746a8ddae821a71fd64f Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Tue, 5 Feb 2019 07:08:48 +0100 Subject: [PATCH] GH-1601 satellite changes to the core --- .../kafka/properties/KafkaExtendedBindingProperties.java | 7 +++++++ .../properties/KafkaStreamsExtendedBindingProperties.java | 7 +++++++ 2 files changed, 14 insertions(+) diff --git a/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaExtendedBindingProperties.java b/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaExtendedBindingProperties.java index 41ba1697b..dbb9a6cd0 100644 --- a/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaExtendedBindingProperties.java +++ b/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaExtendedBindingProperties.java @@ -16,6 +16,8 @@ package org.springframework.cloud.stream.binder.kafka.properties; +import java.util.Map; + import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.cloud.stream.binder.AbstractExtendedBindingProperties; import org.springframework.cloud.stream.binder.BinderSpecificPropertiesProvider; @@ -40,6 +42,11 @@ public class KafkaExtendedBindingProperties extends return DEFAULTS_PREFIX; } + @Override + public Map getBindings() { + return this.doGetBindings(); + } + @Override public Class getExtendedPropertiesEntryClass() { return KafkaBindingProperties.class; diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsExtendedBindingProperties.java b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsExtendedBindingProperties.java index dce595454..16884d80a 100644 --- a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsExtendedBindingProperties.java +++ b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/properties/KafkaStreamsExtendedBindingProperties.java @@ -16,6 +16,8 @@ package org.springframework.cloud.stream.binder.kafka.streams.properties; +import java.util.Map; + import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.cloud.stream.binder.AbstractExtendedBindingProperties; import org.springframework.cloud.stream.binder.BinderSpecificPropertiesProvider; @@ -41,6 +43,11 @@ public class KafkaStreamsExtendedBindingProperties return DEFAULTS_PREFIX; } + @Override + public Map getBindings() { + return this.doGetBindings(); + } + @Override public Class getExtendedPropertiesEntryClass() { return KafkaStreamsBindingProperties.class;