diff --git a/spring-kafka/src/main/java/org/springframework/kafka/annotation/EnableKafkaStreams.java b/spring-kafka/src/main/java/org/springframework/kafka/annotation/EnableKafkaStreams.java index 54a6d43c..9499c45b 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/annotation/EnableKafkaStreams.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/annotation/EnableKafkaStreams.java @@ -23,7 +23,7 @@ import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; import org.springframework.context.annotation.Import; -import org.springframework.kafka.core.StreamsBuilderFactoryBean; +import org.springframework.kafka.config.StreamsBuilderFactoryBean; /** * Enable default Kafka Streams components. To be used on diff --git a/spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaStreamsDefaultConfiguration.java b/spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaStreamsDefaultConfiguration.java index c09c1145..ecfd7e60 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaStreamsDefaultConfiguration.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaStreamsDefaultConfiguration.java @@ -24,7 +24,7 @@ import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.kafka.config.KafkaStreamsConfiguration; -import org.springframework.kafka.core.StreamsBuilderFactoryBean; +import org.springframework.kafka.config.StreamsBuilderFactoryBean; /** * {@code @Configuration} class that registers a {@link StreamsBuilderFactoryBean} diff --git a/spring-kafka/src/main/java/org/springframework/kafka/core/CompositeKafkaStreamsCustomizer.java b/spring-kafka/src/main/java/org/springframework/kafka/config/CompositeKafkaStreamsCustomizer.java similarity index 97% rename from spring-kafka/src/main/java/org/springframework/kafka/core/CompositeKafkaStreamsCustomizer.java rename to spring-kafka/src/main/java/org/springframework/kafka/config/CompositeKafkaStreamsCustomizer.java index c8e3bdff..7128920b 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/core/CompositeKafkaStreamsCustomizer.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/config/CompositeKafkaStreamsCustomizer.java @@ -14,7 +14,7 @@ * limitations under the License. */ -package org.springframework.kafka.core; +package org.springframework.kafka.config; import java.util.ArrayList; import java.util.List; diff --git a/spring-kafka/src/main/java/org/springframework/kafka/core/KafkaStreamsCustomizer.java b/spring-kafka/src/main/java/org/springframework/kafka/config/KafkaStreamsCustomizer.java similarity index 95% rename from spring-kafka/src/main/java/org/springframework/kafka/core/KafkaStreamsCustomizer.java rename to spring-kafka/src/main/java/org/springframework/kafka/config/KafkaStreamsCustomizer.java index a3c947fa..cd5db5f7 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/core/KafkaStreamsCustomizer.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/config/KafkaStreamsCustomizer.java @@ -14,7 +14,7 @@ * limitations under the License. */ -package org.springframework.kafka.core; +package org.springframework.kafka.config; import org.apache.kafka.streams.KafkaStreams; diff --git a/spring-kafka/src/main/java/org/springframework/kafka/core/StreamsBuilderFactoryBean.java b/spring-kafka/src/main/java/org/springframework/kafka/config/StreamsBuilderFactoryBean.java similarity index 99% rename from spring-kafka/src/main/java/org/springframework/kafka/core/StreamsBuilderFactoryBean.java rename to spring-kafka/src/main/java/org/springframework/kafka/config/StreamsBuilderFactoryBean.java index 450a5e58..57737a8e 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/core/StreamsBuilderFactoryBean.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/config/StreamsBuilderFactoryBean.java @@ -14,7 +14,7 @@ * limitations under the License. */ -package org.springframework.kafka.core; +package org.springframework.kafka.config; import java.util.Map; import java.util.Properties; @@ -31,7 +31,7 @@ import org.apache.kafka.streams.processor.internals.DefaultKafkaClientSupplier; import org.springframework.beans.factory.config.AbstractFactoryBean; import org.springframework.context.SmartLifecycle; import org.springframework.kafka.KafkaException; -import org.springframework.kafka.config.KafkaStreamsConfiguration; +import org.springframework.kafka.core.CleanupConfig; import org.springframework.lang.Nullable; import org.springframework.util.Assert; diff --git a/spring-kafka/src/test/java/org/springframework/kafka/core/KafkaStreamsCustomizerTests.java b/spring-kafka/src/test/java/org/springframework/kafka/config/KafkaStreamsCustomizerTests.java similarity index 97% rename from spring-kafka/src/test/java/org/springframework/kafka/core/KafkaStreamsCustomizerTests.java rename to spring-kafka/src/test/java/org/springframework/kafka/config/KafkaStreamsCustomizerTests.java index c50c4e1e..92c91ba2 100644 --- a/spring-kafka/src/test/java/org/springframework/kafka/core/KafkaStreamsCustomizerTests.java +++ b/spring-kafka/src/test/java/org/springframework/kafka/config/KafkaStreamsCustomizerTests.java @@ -14,7 +14,7 @@ * limitations under the License. */ -package org.springframework.kafka.core; +package org.springframework.kafka.config; import static org.assertj.core.api.Assertions.assertThat; @@ -32,7 +32,6 @@ import org.springframework.context.annotation.Configuration; import org.springframework.kafka.annotation.EnableKafka; import org.springframework.kafka.annotation.EnableKafkaStreams; import org.springframework.kafka.annotation.KafkaStreamsDefaultConfiguration; -import org.springframework.kafka.config.KafkaStreamsConfiguration; import org.springframework.kafka.test.EmbeddedKafkaBroker; import org.springframework.kafka.test.context.EmbeddedKafka; import org.springframework.test.annotation.DirtiesContext; diff --git a/spring-kafka/src/test/java/org/springframework/kafka/core/StreamsBuilderFactoryBeanTests.java b/spring-kafka/src/test/java/org/springframework/kafka/config/StreamsBuilderFactoryBeanTests.java similarity index 97% rename from spring-kafka/src/test/java/org/springframework/kafka/core/StreamsBuilderFactoryBeanTests.java rename to spring-kafka/src/test/java/org/springframework/kafka/config/StreamsBuilderFactoryBeanTests.java index 09e8d11e..98ed7aaf 100644 --- a/spring-kafka/src/test/java/org/springframework/kafka/core/StreamsBuilderFactoryBeanTests.java +++ b/spring-kafka/src/test/java/org/springframework/kafka/config/StreamsBuilderFactoryBeanTests.java @@ -14,7 +14,7 @@ * limitations under the License. */ -package org.springframework.kafka.core; +package org.springframework.kafka.config; import static org.assertj.core.api.Assertions.assertThat; @@ -37,7 +37,7 @@ import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.kafka.annotation.EnableKafkaStreams; import org.springframework.kafka.annotation.KafkaStreamsDefaultConfiguration; -import org.springframework.kafka.config.KafkaStreamsConfiguration; +import org.springframework.kafka.core.CleanupConfig; import org.springframework.kafka.test.EmbeddedKafkaBroker; import org.springframework.kafka.test.context.EmbeddedKafka; import org.springframework.test.annotation.DirtiesContext; diff --git a/spring-kafka/src/test/java/org/springframework/kafka/core/StreamsBuilderFactoryLateConfigTests.java b/spring-kafka/src/test/java/org/springframework/kafka/config/StreamsBuilderFactoryLateConfigTests.java similarity index 98% rename from spring-kafka/src/test/java/org/springframework/kafka/core/StreamsBuilderFactoryLateConfigTests.java rename to spring-kafka/src/test/java/org/springframework/kafka/config/StreamsBuilderFactoryLateConfigTests.java index 5714b780..b735e26f 100644 --- a/spring-kafka/src/test/java/org/springframework/kafka/core/StreamsBuilderFactoryLateConfigTests.java +++ b/spring-kafka/src/test/java/org/springframework/kafka/config/StreamsBuilderFactoryLateConfigTests.java @@ -14,7 +14,7 @@ * limitations under the License. */ -package org.springframework.kafka.core; +package org.springframework.kafka.config; import static org.assertj.core.api.Assertions.assertThat; diff --git a/spring-kafka/src/test/java/org/springframework/kafka/kstream/KafkaStreamsTests.java b/spring-kafka/src/test/java/org/springframework/kafka/kstream/KafkaStreamsTests.java index 7cf22f58..b006d06e 100644 --- a/spring-kafka/src/test/java/org/springframework/kafka/kstream/KafkaStreamsTests.java +++ b/spring-kafka/src/test/java/org/springframework/kafka/kstream/KafkaStreamsTests.java @@ -54,12 +54,12 @@ import org.springframework.kafka.annotation.KafkaStreamsDefaultConfiguration; import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory; import org.springframework.kafka.config.KafkaListenerContainerFactory; import org.springframework.kafka.config.KafkaStreamsConfiguration; +import org.springframework.kafka.config.StreamsBuilderFactoryBean; import org.springframework.kafka.core.ConsumerFactory; import org.springframework.kafka.core.DefaultKafkaConsumerFactory; import org.springframework.kafka.core.DefaultKafkaProducerFactory; import org.springframework.kafka.core.KafkaTemplate; import org.springframework.kafka.core.ProducerFactory; -import org.springframework.kafka.core.StreamsBuilderFactoryBean; import org.springframework.kafka.listener.ConcurrentMessageListenerContainer; import org.springframework.kafka.support.serializer.JsonSerde; import org.springframework.kafka.test.EmbeddedKafkaBroker; diff --git a/src/reference/asciidoc/whats-new.adoc b/src/reference/asciidoc/whats-new.adoc index a65c4880..2ffc69a9 100644 --- a/src/reference/asciidoc/whats-new.adoc +++ b/src/reference/asciidoc/whats-new.adoc @@ -78,6 +78,8 @@ See <> for more information. The streams configuration bean must now be a simple `Properties` object instead of a `StreamsConfig`. +The `StreamsBuilderFactoryBean` has been moved from package `...core` to `...config`. + See <> for more information.