Update

bakdata · May 16, 2024 · 71d325d · 71d325d
1 parent b2ee7e2
commit 71d325d
Show file tree

Hide file tree

Showing 112 changed files with 13 additions and 13 deletions.
diff --git a/README.md b/README.md
@@ -26,7 +26,7 @@ You can add streams-bootstrap via Maven Central.
 #### Gradle
 
 ```gradle
-implementation group: 'com.bakdata.kafka', name: 'streams-bootstrap', version: '3.0.0'
+implementation group: 'com.bakdata.kafka', name: 'streams-bootstrap-cli', version: '3.0.0'
 ```
 
 #### Maven
@@ -35,7 +35,7 @@ implementation group: 'com.bakdata.kafka', name: 'streams-bootstrap', version: '
 
 <dependency>
     <groupId>com.bakdata.kafka</groupId>
-    <artifactId>streams-bootstrap</artifactId>
+  <artifactId>streams-bootstrap-cli</artifactId>
   <version>3.0.0</version>
 </dependency>
 ```

diff --git a/settings.gradle b/settings.gradle
@@ -7,8 +7,8 @@ pluginManagement {
 rootProject.name = 'streams-bootstrap'
 
 include(
-        ":streams-bootstrap",
+        ":streams-bootstrap-core",
         ":streams-bootstrap-test",
         ":streams-bootstrap-large-messages",
-        ":streams-bootstrap-picocli",
+        ":streams-bootstrap-cli",
 )
diff --git a/streams-bootstrap-picocli/build.gradle.kts → streams-bootstrap-cli/build.gradle.kts b/streams-bootstrap-picocli/build.gradle.kts → streams-bootstrap-cli/build.gradle.kts
@@ -5,7 +5,7 @@ plugins {
 }
 
 dependencies {
-    api(project(":streams-bootstrap"))
+    api(project(":streams-bootstrap-core"))
     api(group = "info.picocli", name = "picocli", version = "4.7.5")
     val log4jVersion: String by project
     implementation(group = "org.apache.logging.log4j", name = "log4j-core", version = log4jVersion)

diff --git a/...ata/kafka/EnvironmentArgumentsParser.java → ...ata/kafka/EnvironmentArgumentsParser.java b/...ata/kafka/EnvironmentArgumentsParser.java → ...ata/kafka/EnvironmentArgumentsParser.java
diff --git a/...a/com/bakdata/kafka/KafkaApplication.java → ...a/com/bakdata/kafka/KafkaApplication.java b/...a/com/bakdata/kafka/KafkaApplication.java → ...a/com/bakdata/kafka/KafkaApplication.java
diff --git a/...kdata/kafka/KafkaProducerApplication.java → ...kdata/kafka/KafkaProducerApplication.java b/...kdata/kafka/KafkaProducerApplication.java → ...kdata/kafka/KafkaProducerApplication.java
diff --git a/...akdata/kafka/KafkaStreamsApplication.java → ...akdata/kafka/KafkaStreamsApplication.java b/...akdata/kafka/KafkaStreamsApplication.java → ...akdata/kafka/KafkaStreamsApplication.java
diff --git a/...kafka/SimpleKafkaProducerApplication.java → ...kafka/SimpleKafkaProducerApplication.java b/...kafka/SimpleKafkaProducerApplication.java → ...kafka/SimpleKafkaProducerApplication.java
diff --git a/.../kafka/SimpleKafkaStreamsApplication.java → .../kafka/SimpleKafkaStreamsApplication.java b/.../kafka/SimpleKafkaStreamsApplication.java → .../kafka/SimpleKafkaStreamsApplication.java
diff --git a/...om/bakdata/kafka/StringListConverter.java → ...om/bakdata/kafka/StringListConverter.java b/...om/bakdata/kafka/StringListConverter.java → ...om/bakdata/kafka/StringListConverter.java
diff --git a/...rap-picocli/src/test/avro/TestRecord.avsc → ...otstrap-cli/src/test/avro/TestRecord.avsc b/...rap-picocli/src/test/avro/TestRecord.avsc → ...otstrap-cli/src/test/avro/TestRecord.avsc
diff --git a/.../test/java/com/bakdata/kafka/CliTest.java → .../test/java/com/bakdata/kafka/CliTest.java b/.../test/java/com/bakdata/kafka/CliTest.java → .../test/java/com/bakdata/kafka/CliTest.java
diff --git a/.../java/com/bakdata/kafka/CloseFlagApp.java → .../java/com/bakdata/kafka/CloseFlagApp.java b/.../java/com/bakdata/kafka/CloseFlagApp.java → .../java/com/bakdata/kafka/CloseFlagApp.java
diff --git a/...kafka/EnvironmentArgumentsParserTest.java → ...kafka/EnvironmentArgumentsParserTest.java b/...kafka/EnvironmentArgumentsParserTest.java → ...kafka/EnvironmentArgumentsParserTest.java
diff --git a/...akdata/kafka/StringListConverterTest.java → ...akdata/kafka/StringListConverterTest.java b/...akdata/kafka/StringListConverterTest.java → ...akdata/kafka/StringListConverterTest.java
diff --git a/...test/java/com/bakdata/kafka/TestUtil.java → ...test/java/com/bakdata/kafka/TestUtil.java b/...test/java/com/bakdata/kafka/TestUtil.java → ...test/java/com/bakdata/kafka/TestUtil.java
diff --git a/...kafka/integration/RunProducerAppTest.java → ...kafka/integration/RunProducerAppTest.java b/...kafka/integration/RunProducerAppTest.java → ...kafka/integration/RunProducerAppTest.java
diff --git a/.../kafka/integration/RunStreamsAppTest.java → .../kafka/integration/RunStreamsAppTest.java b/.../kafka/integration/RunStreamsAppTest.java → .../kafka/integration/RunStreamsAppTest.java
diff --git a/...kafka/integration/StreamsCleanUpTest.java → ...kafka/integration/StreamsCleanUpTest.java b/...kafka/integration/StreamsCleanUpTest.java → ...kafka/integration/StreamsCleanUpTest.java
diff --git a/...kdata/kafka/test_applications/Mirror.java → ...kdata/kafka/test_applications/Mirror.java b/...kdata/kafka/test_applications/Mirror.java → ...kdata/kafka/test_applications/Mirror.java
diff --git a/...ta/kafka/test_applications/WordCount.java → ...ta/kafka/test_applications/WordCount.java b/...ta/kafka/test_applications/WordCount.java → ...ta/kafka/test_applications/WordCount.java
diff --git a/...rap-picocli/src/test/resources/log4j2.xml → ...otstrap-cli/src/test/resources/log4j2.xml b/...rap-picocli/src/test/resources/log4j2.xml → ...otstrap-cli/src/test/resources/log4j2.xml
diff --git a/streams-bootstrap/build.gradle.kts → streams-bootstrap-core/build.gradle.kts b/streams-bootstrap/build.gradle.kts → streams-bootstrap-core/build.gradle.kts
diff --git a/streams-bootstrap/lombok.config → streams-bootstrap-core/lombok.config b/streams-bootstrap/lombok.config → streams-bootstrap-core/lombok.config
diff --git a/.../src/main/java/com/bakdata/kafka/App.java → .../src/main/java/com/bakdata/kafka/App.java b/.../src/main/java/com/bakdata/kafka/App.java → .../src/main/java/com/bakdata/kafka/App.java
diff --git a/...a/com/bakdata/kafka/AppConfiguration.java → ...a/com/bakdata/kafka/AppConfiguration.java b/...a/com/bakdata/kafka/AppConfiguration.java → ...a/com/bakdata/kafka/AppConfiguration.java
diff --git a/...uringStreamsUncaughtExceptionHandler.java → ...uringStreamsUncaughtExceptionHandler.java b/...uringStreamsUncaughtExceptionHandler.java → ...uringStreamsUncaughtExceptionHandler.java
diff --git a/...a/com/bakdata/kafka/CleanUpException.java → ...a/com/bakdata/kafka/CleanUpException.java b/...a/com/bakdata/kafka/CleanUpException.java → ...a/com/bakdata/kafka/CleanUpException.java
diff --git a/...java/com/bakdata/kafka/CleanUpRunner.java → ...java/com/bakdata/kafka/CleanUpRunner.java b/...java/com/bakdata/kafka/CleanUpRunner.java → ...java/com/bakdata/kafka/CleanUpRunner.java
diff --git a/.../java/com/bakdata/kafka/Configurable.java → .../java/com/bakdata/kafka/Configurable.java b/.../java/com/bakdata/kafka/Configurable.java → .../java/com/bakdata/kafka/Configurable.java
diff --git a/.../com/bakdata/kafka/ConfigurableSerde.java → .../com/bakdata/kafka/ConfigurableSerde.java b/.../com/bakdata/kafka/ConfigurableSerde.java → .../com/bakdata/kafka/ConfigurableSerde.java
diff --git a/...bakdata/kafka/ConfigurableSerializer.java → ...bakdata/kafka/ConfigurableSerializer.java b/...bakdata/kafka/ConfigurableSerializer.java → ...bakdata/kafka/ConfigurableSerializer.java
diff --git a/.../java/com/bakdata/kafka/Configurator.java → .../java/com/bakdata/kafka/Configurator.java b/.../java/com/bakdata/kafka/Configurator.java → .../java/com/bakdata/kafka/Configurator.java
diff --git a/...java/com/bakdata/kafka/ConfiguredApp.java → ...java/com/bakdata/kafka/ConfiguredApp.java b/...java/com/bakdata/kafka/ConfiguredApp.java → ...java/com/bakdata/kafka/ConfiguredApp.java
diff --git a/.../bakdata/kafka/ConfiguredProducerApp.java → .../bakdata/kafka/ConfiguredProducerApp.java b/.../bakdata/kafka/ConfiguredProducerApp.java → .../bakdata/kafka/ConfiguredProducerApp.java
diff --git a/...m/bakdata/kafka/ConfiguredStreamsApp.java → ...m/bakdata/kafka/ConfiguredStreamsApp.java b/...m/bakdata/kafka/ConfiguredStreamsApp.java → ...m/bakdata/kafka/ConfiguredStreamsApp.java
diff --git a/...om/bakdata/kafka/DefaultConfigurable.java → ...om/bakdata/kafka/DefaultConfigurable.java b/...om/bakdata/kafka/DefaultConfigurable.java → ...om/bakdata/kafka/DefaultConfigurable.java
diff --git a/...faultStreamsUncaughtExceptionHandler.java → ...faultStreamsUncaughtExceptionHandler.java b/...faultStreamsUncaughtExceptionHandler.java → ...faultStreamsUncaughtExceptionHandler.java
diff --git a/...data/kafka/EffectiveAppConfiguration.java → ...data/kafka/EffectiveAppConfiguration.java b/...data/kafka/EffectiveAppConfiguration.java → ...data/kafka/EffectiveAppConfiguration.java
diff --git a/...kafka/EnvironmentStreamsConfigParser.java → ...kafka/EnvironmentStreamsConfigParser.java b/...kafka/EnvironmentStreamsConfigParser.java → ...kafka/EnvironmentStreamsConfigParser.java
diff --git a/...java/com/bakdata/kafka/ExecutableApp.java → ...java/com/bakdata/kafka/ExecutableApp.java b/...java/com/bakdata/kafka/ExecutableApp.java → ...java/com/bakdata/kafka/ExecutableApp.java
diff --git a/.../bakdata/kafka/ExecutableProducerApp.java → .../bakdata/kafka/ExecutableProducerApp.java b/.../bakdata/kafka/ExecutableProducerApp.java → .../bakdata/kafka/ExecutableProducerApp.java
diff --git a/...m/bakdata/kafka/ExecutableStreamsApp.java → ...m/bakdata/kafka/ExecutableStreamsApp.java b/...m/bakdata/kafka/ExecutableStreamsApp.java → ...m/bakdata/kafka/ExecutableStreamsApp.java
diff --git a/.../java/com/bakdata/kafka/HasCleanHook.java → .../java/com/bakdata/kafka/HasCleanHook.java b/.../java/com/bakdata/kafka/HasCleanHook.java → .../java/com/bakdata/kafka/HasCleanHook.java
diff --git a/...java/com/bakdata/kafka/HasTopicHooks.java → ...java/com/bakdata/kafka/HasTopicHooks.java b/...java/com/bakdata/kafka/HasTopicHooks.java → ...java/com/bakdata/kafka/HasTopicHooks.java
diff --git a/.../bakdata/kafka/ImprovedStreamsConfig.java → .../bakdata/kafka/ImprovedStreamsConfig.java b/.../bakdata/kafka/ImprovedStreamsConfig.java → .../bakdata/kafka/ImprovedStreamsConfig.java
diff --git a/...om/bakdata/kafka/KafkaEndpointConfig.java → ...om/bakdata/kafka/KafkaEndpointConfig.java b/...om/bakdata/kafka/KafkaEndpointConfig.java → ...om/bakdata/kafka/KafkaEndpointConfig.java
diff --git a/...bakdata/kafka/KafkaPropertiesFactory.java → ...bakdata/kafka/KafkaPropertiesFactory.java b/...bakdata/kafka/KafkaPropertiesFactory.java → ...bakdata/kafka/KafkaPropertiesFactory.java
diff --git a/.../com/bakdata/kafka/NoOpStateListener.java → .../com/bakdata/kafka/NoOpStateListener.java b/.../com/bakdata/kafka/NoOpStateListener.java → .../com/bakdata/kafka/NoOpStateListener.java
diff --git a/...java/com/bakdata/kafka/Preconfigured.java → ...java/com/bakdata/kafka/Preconfigured.java b/...java/com/bakdata/kafka/Preconfigured.java → ...java/com/bakdata/kafka/Preconfigured.java
diff --git a/...n/java/com/bakdata/kafka/ProducerApp.java → ...n/java/com/bakdata/kafka/ProducerApp.java b/...n/java/com/bakdata/kafka/ProducerApp.java → ...n/java/com/bakdata/kafka/ProducerApp.java
diff --git a/...va/com/bakdata/kafka/ProducerBuilder.java → ...va/com/bakdata/kafka/ProducerBuilder.java b/...va/com/bakdata/kafka/ProducerBuilder.java → ...va/com/bakdata/kafka/ProducerBuilder.java
diff --git a/...a/kafka/ProducerCleanUpConfiguration.java → ...a/kafka/ProducerCleanUpConfiguration.java b/...a/kafka/ProducerCleanUpConfiguration.java → ...a/kafka/ProducerCleanUpConfiguration.java
diff --git a/.../bakdata/kafka/ProducerCleanUpRunner.java → .../bakdata/kafka/ProducerCleanUpRunner.java b/.../bakdata/kafka/ProducerCleanUpRunner.java → .../bakdata/kafka/ProducerCleanUpRunner.java
diff --git a/...kdata/kafka/ProducerExecutionOptions.java → ...kdata/kafka/ProducerExecutionOptions.java b/...kdata/kafka/ProducerExecutionOptions.java → ...kdata/kafka/ProducerExecutionOptions.java
diff --git a/...a/com/bakdata/kafka/ProducerRunnable.java → ...a/com/bakdata/kafka/ProducerRunnable.java b/...a/com/bakdata/kafka/ProducerRunnable.java → ...a/com/bakdata/kafka/ProducerRunnable.java
diff --git a/...ava/com/bakdata/kafka/ProducerRunner.java → ...ava/com/bakdata/kafka/ProducerRunner.java b/...ava/com/bakdata/kafka/ProducerRunner.java → ...ava/com/bakdata/kafka/ProducerRunner.java
diff --git a/...om/bakdata/kafka/ProducerTopicConfig.java → ...om/bakdata/kafka/ProducerTopicConfig.java b/...om/bakdata/kafka/ProducerTopicConfig.java → ...om/bakdata/kafka/ProducerTopicConfig.java
diff --git a/...c/main/java/com/bakdata/kafka/Runner.java → ...c/main/java/com/bakdata/kafka/Runner.java b/...c/main/java/com/bakdata/kafka/Runner.java → ...c/main/java/com/bakdata/kafka/Runner.java
diff --git a/...in/java/com/bakdata/kafka/StreamsApp.java → ...in/java/com/bakdata/kafka/StreamsApp.java b/...in/java/com/bakdata/kafka/StreamsApp.java → ...in/java/com/bakdata/kafka/StreamsApp.java
diff --git a/...ta/kafka/StreamsApplicationException.java → ...ta/kafka/StreamsApplicationException.java b/...ta/kafka/StreamsApplicationException.java → ...ta/kafka/StreamsApplicationException.java
@@ -1,7 +1,7 @@
 /*
  * MIT License
  *
- * Copyright (c) 2023 bakdata
+ * Copyright (c) 2024 bakdata
  *
  * Permission is hereby granted, free of charge, to any person obtaining a copy
  * of this software and associated documentation files (the "Software"), to deal

diff --git a/...ta/kafka/StreamsCleanUpConfiguration.java → ...ta/kafka/StreamsCleanUpConfiguration.java b/...ta/kafka/StreamsCleanUpConfiguration.java → ...ta/kafka/StreamsCleanUpConfiguration.java
diff --git a/...m/bakdata/kafka/StreamsCleanUpRunner.java → ...m/bakdata/kafka/StreamsCleanUpRunner.java b/...m/bakdata/kafka/StreamsCleanUpRunner.java → ...m/bakdata/kafka/StreamsCleanUpRunner.java
diff --git a/...akdata/kafka/StreamsExecutionOptions.java → ...akdata/kafka/StreamsExecutionOptions.java b/...akdata/kafka/StreamsExecutionOptions.java → ...akdata/kafka/StreamsExecutionOptions.java
diff --git a/...java/com/bakdata/kafka/StreamsRunner.java → ...java/com/bakdata/kafka/StreamsRunner.java b/...java/com/bakdata/kafka/StreamsRunner.java → ...java/com/bakdata/kafka/StreamsRunner.java
diff --git a/...a/kafka/StreamsShutdownStateListener.java → ...a/kafka/StreamsShutdownStateListener.java b/...a/kafka/StreamsShutdownStateListener.java → ...a/kafka/StreamsShutdownStateListener.java
diff --git a/...com/bakdata/kafka/StreamsTopicConfig.java → ...com/bakdata/kafka/StreamsTopicConfig.java b/...com/bakdata/kafka/StreamsTopicConfig.java → ...com/bakdata/kafka/StreamsTopicConfig.java
diff --git a/...va/com/bakdata/kafka/TopologyBuilder.java → ...va/com/bakdata/kafka/TopologyBuilder.java b/...va/com/bakdata/kafka/TopologyBuilder.java → ...va/com/bakdata/kafka/TopologyBuilder.java
diff --git a/...kdata/kafka/util/ConsumerGroupClient.java → ...kdata/kafka/util/ConsumerGroupClient.java b/...kdata/kafka/util/ConsumerGroupClient.java → ...kdata/kafka/util/ConsumerGroupClient.java
diff --git a/...a/kafka/util/DirectTopicSubscription.java → ...a/kafka/util/DirectTopicSubscription.java b/...a/kafka/util/DirectTopicSubscription.java → ...a/kafka/util/DirectTopicSubscription.java
@@ -1,7 +1,7 @@
 /*
  * MIT License
  *
- * Copyright (c) 2023 bakdata
+ * Copyright (c) 2024 bakdata
  *
  * Permission is hereby granted, free of charge, to any person obtaining a copy
  * of this software and associated documentation files (the "Software"), to deal

diff --git a/...kdata/kafka/util/ImprovedAdminClient.java → ...kdata/kafka/util/ImprovedAdminClient.java b/...kdata/kafka/util/ImprovedAdminClient.java → ...kdata/kafka/util/ImprovedAdminClient.java
diff --git a/...kdata/kafka/util/KafkaAdminException.java → ...kdata/kafka/util/KafkaAdminException.java b/...kdata/kafka/util/KafkaAdminException.java → ...kdata/kafka/util/KafkaAdminException.java
@@ -1,7 +1,7 @@
 /*
  * MIT License
  *
- * Copyright (c) 2023 bakdata
+ * Copyright (c) 2024 bakdata
  *
  * Permission is hereby granted, free of charge, to any person obtaining a copy
  * of this software and associated documentation files (the "Software"), to deal

diff --git a/.../kafka/util/PatternTopicSubscription.java → .../kafka/util/PatternTopicSubscription.java b/.../kafka/util/PatternTopicSubscription.java → .../kafka/util/PatternTopicSubscription.java
@@ -1,7 +1,7 @@
 /*
  * MIT License
  *
- * Copyright (c) 2023 bakdata
+ * Copyright (c) 2024 bakdata
  *
  * Permission is hereby granted, free of charge, to any person obtaining a copy
  * of this software and associated documentation files (the "Software"), to deal

diff --git a/...bakdata/kafka/util/SchemaTopicClient.java → ...bakdata/kafka/util/SchemaTopicClient.java b/...bakdata/kafka/util/SchemaTopicClient.java → ...bakdata/kafka/util/SchemaTopicClient.java
diff --git a/...a/com/bakdata/kafka/util/TopicClient.java → ...a/com/bakdata/kafka/util/TopicClient.java b/...a/com/bakdata/kafka/util/TopicClient.java → ...a/com/bakdata/kafka/util/TopicClient.java
diff --git a/...com/bakdata/kafka/util/TopicSettings.java → ...com/bakdata/kafka/util/TopicSettings.java b/...com/bakdata/kafka/util/TopicSettings.java → ...com/bakdata/kafka/util/TopicSettings.java
@@ -1,7 +1,7 @@
 /*
  * MIT License
  *
- * Copyright (c) 2023 bakdata
+ * Copyright (c) 2024 bakdata
  *
  * Permission is hereby granted, free of charge, to any person obtaining a copy
  * of this software and associated documentation files (the "Software"), to deal

diff --git a/...bakdata/kafka/util/TopicSubscription.java → ...bakdata/kafka/util/TopicSubscription.java b/...bakdata/kafka/util/TopicSubscription.java → ...bakdata/kafka/util/TopicSubscription.java
@@ -1,7 +1,7 @@
 /*
  * MIT License
  *
- * Copyright (c) 2023 bakdata
+ * Copyright (c) 2024 bakdata
  *
  * Permission is hereby granted, free of charge, to any person obtaining a copy
  * of this software and associated documentation files (the "Software"), to deal

diff --git a/...kdata/kafka/util/TopologyInformation.java → ...kdata/kafka/util/TopologyInformation.java b/...kdata/kafka/util/TopologyInformation.java → ...kdata/kafka/util/TopologyInformation.java
diff --git a/...s-bootstrap/src/test/avro/TestRecord.avsc → ...tstrap-core/src/test/avro/TestRecord.avsc b/...s-bootstrap/src/test/avro/TestRecord.avsc → ...tstrap-core/src/test/avro/TestRecord.avsc
diff --git a/...ava/com/bakdata/kafka/AvroMirrorTest.java → ...ava/com/bakdata/kafka/AvroMirrorTest.java b/...ava/com/bakdata/kafka/AvroMirrorTest.java → ...ava/com/bakdata/kafka/AvroMirrorTest.java
diff --git a/...a/com/bakdata/kafka/ConfiguratorTest.java → ...a/com/bakdata/kafka/ConfiguratorTest.java b/...a/com/bakdata/kafka/ConfiguratorTest.java → ...a/com/bakdata/kafka/ConfiguratorTest.java
diff --git a/...data/kafka/ConfiguredProducerAppTest.java → ...data/kafka/ConfiguredProducerAppTest.java b/...data/kafka/ConfiguredProducerAppTest.java → ...data/kafka/ConfiguredProducerAppTest.java
diff --git a/...kdata/kafka/ConfiguredStreamsAppTest.java → ...kdata/kafka/ConfiguredStreamsAppTest.java b/...kdata/kafka/ConfiguredStreamsAppTest.java → ...kdata/kafka/ConfiguredStreamsAppTest.java
diff --git a/...a/EnvironmentStreamsConfigParserTest.java → ...a/EnvironmentStreamsConfigParserTest.java b/...a/EnvironmentStreamsConfigParserTest.java → ...a/EnvironmentStreamsConfigParserTest.java
diff --git a/...data/kafka/ExecutableProducerAppTest.java → ...data/kafka/ExecutableProducerAppTest.java b/...data/kafka/ExecutableProducerAppTest.java → ...data/kafka/ExecutableProducerAppTest.java
diff --git a/...kdata/kafka/ExecutableStreamsAppTest.java → ...kdata/kafka/ExecutableStreamsAppTest.java b/...kdata/kafka/ExecutableStreamsAppTest.java → ...kdata/kafka/ExecutableStreamsAppTest.java
diff --git a/.../com/bakdata/kafka/PreconfiguredTest.java → .../com/bakdata/kafka/PreconfiguredTest.java b/.../com/bakdata/kafka/PreconfiguredTest.java → .../com/bakdata/kafka/PreconfiguredTest.java
diff --git a/...kdata/kafka/StreamsCleanUpRunnerTest.java → ...kdata/kafka/StreamsCleanUpRunnerTest.java b/...kdata/kafka/StreamsCleanUpRunnerTest.java → ...kdata/kafka/StreamsCleanUpRunnerTest.java
diff --git a/...ta/kafka/StreamsExecutionOptionsTest.java → ...ta/kafka/StreamsExecutionOptionsTest.java b/...ta/kafka/StreamsExecutionOptionsTest.java → ...ta/kafka/StreamsExecutionOptionsTest.java
diff --git a/...test/java/com/bakdata/kafka/TestUtil.java → ...test/java/com/bakdata/kafka/TestUtil.java b/...test/java/com/bakdata/kafka/TestUtil.java → ...test/java/com/bakdata/kafka/TestUtil.java
diff --git a/.../bakdata/kafka/integration/KafkaTest.java → .../bakdata/kafka/integration/KafkaTest.java b/.../bakdata/kafka/integration/KafkaTest.java → .../bakdata/kafka/integration/KafkaTest.java
diff --git a/...ntegration/ProducerCleanUpRunnerTest.java → ...ntegration/ProducerCleanUpRunnerTest.java b/...ntegration/ProducerCleanUpRunnerTest.java → ...ntegration/ProducerCleanUpRunnerTest.java
diff --git a/...kafka/integration/ProducerRunnerTest.java → ...kafka/integration/ProducerRunnerTest.java b/...kafka/integration/ProducerRunnerTest.java → ...kafka/integration/ProducerRunnerTest.java
diff --git a/...integration/StreamsCleanUpRunnerTest.java → ...integration/StreamsCleanUpRunnerTest.java b/...integration/StreamsCleanUpRunnerTest.java → ...integration/StreamsCleanUpRunnerTest.java
diff --git a/.../kafka/integration/StreamsRunnerTest.java → .../kafka/integration/StreamsRunnerTest.java b/.../kafka/integration/StreamsRunnerTest.java → .../kafka/integration/StreamsRunnerTest.java
diff --git a/...ka/test_applications/AvroKeyProducer.java → ...ka/test_applications/AvroKeyProducer.java b/...ka/test_applications/AvroKeyProducer.java → ...ka/test_applications/AvroKeyProducer.java
diff --git a/.../test_applications/AvroValueProducer.java → .../test_applications/AvroValueProducer.java b/.../test_applications/AvroValueProducer.java → .../test_applications/AvroValueProducer.java
diff --git a/...lications/ComplexTopologyApplication.java → ...lications/ComplexTopologyApplication.java b/...lications/ComplexTopologyApplication.java → ...lications/ComplexTopologyApplication.java
diff --git a/...a/test_applications/ExtraInputTopics.java → ...a/test_applications/ExtraInputTopics.java b/...a/test_applications/ExtraInputTopics.java → ...a/test_applications/ExtraInputTopics.java
diff --git a/...kdata/kafka/test_applications/Mirror.java → ...kdata/kafka/test_applications/Mirror.java b/...kdata/kafka/test_applications/Mirror.java → ...kdata/kafka/test_applications/Mirror.java
diff --git a/.../test_applications/MirrorKeyWithAvro.java → .../test_applications/MirrorKeyWithAvro.java b/.../test_applications/MirrorKeyWithAvro.java → .../test_applications/MirrorKeyWithAvro.java
diff --git a/...est_applications/MirrorValueWithAvro.java → ...est_applications/MirrorValueWithAvro.java b/...est_applications/MirrorValueWithAvro.java → ...est_applications/MirrorValueWithAvro.java
diff --git a/...plications/MirrorWithNonDefaultSerde.java → ...plications/MirrorWithNonDefaultSerde.java b/...plications/MirrorWithNonDefaultSerde.java → ...plications/MirrorWithNonDefaultSerde.java
diff --git a/...fka/test_applications/StringProducer.java → ...fka/test_applications/StringProducer.java b/...fka/test_applications/StringProducer.java → ...fka/test_applications/StringProducer.java
diff --git a/...ta/kafka/test_applications/WordCount.java → ...ta/kafka/test_applications/WordCount.java b/...ta/kafka/test_applications/WordCount.java → ...ta/kafka/test_applications/WordCount.java
diff --git a/...a/test_applications/WordCountPattern.java → ...a/test_applications/WordCountPattern.java b/...a/test_applications/WordCountPattern.java → ...a/test_applications/WordCountPattern.java
diff --git a/...ata/kafka/util/SchemaTopicClientTest.java → ...ata/kafka/util/SchemaTopicClientTest.java b/...ata/kafka/util/SchemaTopicClientTest.java → ...ata/kafka/util/SchemaTopicClientTest.java
diff --git a/...m/bakdata/kafka/util/TopicClientTest.java → ...m/bakdata/kafka/util/TopicClientTest.java b/...m/bakdata/kafka/util/TopicClientTest.java → ...m/bakdata/kafka/util/TopicClientTest.java
diff --git a/...a/kafka/util/TopologyInformationTest.java → ...a/kafka/util/TopologyInformationTest.java b/...a/kafka/util/TopologyInformationTest.java → ...a/kafka/util/TopologyInformationTest.java
diff --git a/...s-bootstrap/src/test/resources/log4j2.xml → ...tstrap-core/src/test/resources/log4j2.xml b/...s-bootstrap/src/test/resources/log4j2.xml → ...tstrap-core/src/test/resources/log4j2.xml
diff --git a/streams-bootstrap-large-messages/build.gradle.kts b/streams-bootstrap-large-messages/build.gradle.kts
@@ -1,6 +1,6 @@
 description = "Utils for using Large Message SerDe with your Kafka Streams Application"
 
 dependencies {
-    api(project(":streams-bootstrap"))
+    api(project(":streams-bootstrap-core"))
     implementation(group = "com.bakdata.kafka", name = "large-message-core", version = "2.6.0")
 }
diff --git a/streams-bootstrap-test/build.gradle.kts b/streams-bootstrap-test/build.gradle.kts
@@ -1,7 +1,7 @@
 description = "Utils for testing your Kafka Streams Application"
 
 dependencies {
-    api(project(":streams-bootstrap"))
+    api(project(":streams-bootstrap-core"))
     val fluentKafkaVersion: String by project
     api(
         group = "com.bakdata.fluent-kafka-streams-tests",