From 71d325d44722ead620bdc9ae85dd385a654b7446 Mon Sep 17 00:00:00 2001 From: Philipp Schirmer Date: Thu, 16 May 2024 16:04:42 +0200 Subject: [PATCH] Update --- README.md | 4 ++-- settings.gradle | 4 ++-- .../build.gradle.kts | 2 +- .../java/com/bakdata/kafka/EnvironmentArgumentsParser.java | 0 .../src/main/java/com/bakdata/kafka/KafkaApplication.java | 0 .../main/java/com/bakdata/kafka/KafkaProducerApplication.java | 0 .../main/java/com/bakdata/kafka/KafkaStreamsApplication.java | 0 .../com/bakdata/kafka/SimpleKafkaProducerApplication.java | 0 .../java/com/bakdata/kafka/SimpleKafkaStreamsApplication.java | 0 .../src/main/java/com/bakdata/kafka/StringListConverter.java | 0 .../src/test/avro/TestRecord.avsc | 0 .../src/test/java/com/bakdata/kafka/CliTest.java | 0 .../src/test/java/com/bakdata/kafka/CloseFlagApp.java | 0 .../com/bakdata/kafka/EnvironmentArgumentsParserTest.java | 0 .../test/java/com/bakdata/kafka/StringListConverterTest.java | 0 .../src/test/java/com/bakdata/kafka/TestUtil.java | 0 .../com/bakdata/kafka/integration/RunProducerAppTest.java | 0 .../java/com/bakdata/kafka/integration/RunStreamsAppTest.java | 0 .../com/bakdata/kafka/integration/StreamsCleanUpTest.java | 0 .../test/java/com/bakdata/kafka/test_applications/Mirror.java | 0 .../java/com/bakdata/kafka/test_applications/WordCount.java | 0 .../src/test/resources/log4j2.xml | 0 .../build.gradle.kts | 0 {streams-bootstrap => streams-bootstrap-core}/lombok.config | 0 .../src/main/java/com/bakdata/kafka/App.java | 0 .../src/main/java/com/bakdata/kafka/AppConfiguration.java | 0 .../kafka/CapturingStreamsUncaughtExceptionHandler.java | 0 .../src/main/java/com/bakdata/kafka/CleanUpException.java | 0 .../src/main/java/com/bakdata/kafka/CleanUpRunner.java | 0 .../src/main/java/com/bakdata/kafka/Configurable.java | 0 .../src/main/java/com/bakdata/kafka/ConfigurableSerde.java | 0 .../main/java/com/bakdata/kafka/ConfigurableSerializer.java | 0 .../src/main/java/com/bakdata/kafka/Configurator.java | 0 .../src/main/java/com/bakdata/kafka/ConfiguredApp.java | 0 .../main/java/com/bakdata/kafka/ConfiguredProducerApp.java | 0 .../src/main/java/com/bakdata/kafka/ConfiguredStreamsApp.java | 0 .../src/main/java/com/bakdata/kafka/DefaultConfigurable.java | 0 .../bakdata/kafka/DefaultStreamsUncaughtExceptionHandler.java | 0 .../java/com/bakdata/kafka/EffectiveAppConfiguration.java | 0 .../com/bakdata/kafka/EnvironmentStreamsConfigParser.java | 0 .../src/main/java/com/bakdata/kafka/ExecutableApp.java | 0 .../main/java/com/bakdata/kafka/ExecutableProducerApp.java | 0 .../src/main/java/com/bakdata/kafka/ExecutableStreamsApp.java | 0 .../src/main/java/com/bakdata/kafka/HasCleanHook.java | 0 .../src/main/java/com/bakdata/kafka/HasTopicHooks.java | 0 .../main/java/com/bakdata/kafka/ImprovedStreamsConfig.java | 0 .../src/main/java/com/bakdata/kafka/KafkaEndpointConfig.java | 0 .../main/java/com/bakdata/kafka/KafkaPropertiesFactory.java | 0 .../src/main/java/com/bakdata/kafka/NoOpStateListener.java | 0 .../src/main/java/com/bakdata/kafka/Preconfigured.java | 0 .../src/main/java/com/bakdata/kafka/ProducerApp.java | 0 .../src/main/java/com/bakdata/kafka/ProducerBuilder.java | 0 .../java/com/bakdata/kafka/ProducerCleanUpConfiguration.java | 0 .../main/java/com/bakdata/kafka/ProducerCleanUpRunner.java | 0 .../main/java/com/bakdata/kafka/ProducerExecutionOptions.java | 0 .../src/main/java/com/bakdata/kafka/ProducerRunnable.java | 0 .../src/main/java/com/bakdata/kafka/ProducerRunner.java | 0 .../src/main/java/com/bakdata/kafka/ProducerTopicConfig.java | 0 .../src/main/java/com/bakdata/kafka/Runner.java | 0 .../src/main/java/com/bakdata/kafka/StreamsApp.java | 0 .../java/com/bakdata/kafka/StreamsApplicationException.java | 2 +- .../java/com/bakdata/kafka/StreamsCleanUpConfiguration.java | 0 .../src/main/java/com/bakdata/kafka/StreamsCleanUpRunner.java | 0 .../main/java/com/bakdata/kafka/StreamsExecutionOptions.java | 0 .../src/main/java/com/bakdata/kafka/StreamsRunner.java | 0 .../java/com/bakdata/kafka/StreamsShutdownStateListener.java | 0 .../src/main/java/com/bakdata/kafka/StreamsTopicConfig.java | 0 .../src/main/java/com/bakdata/kafka/TopologyBuilder.java | 0 .../main/java/com/bakdata/kafka/util/ConsumerGroupClient.java | 0 .../java/com/bakdata/kafka/util/DirectTopicSubscription.java | 2 +- .../main/java/com/bakdata/kafka/util/ImprovedAdminClient.java | 0 .../main/java/com/bakdata/kafka/util/KafkaAdminException.java | 2 +- .../java/com/bakdata/kafka/util/PatternTopicSubscription.java | 2 +- .../main/java/com/bakdata/kafka/util/SchemaTopicClient.java | 0 .../src/main/java/com/bakdata/kafka/util/TopicClient.java | 0 .../src/main/java/com/bakdata/kafka/util/TopicSettings.java | 2 +- .../main/java/com/bakdata/kafka/util/TopicSubscription.java | 2 +- .../main/java/com/bakdata/kafka/util/TopologyInformation.java | 0 .../src/test/avro/TestRecord.avsc | 0 .../src/test/java/com/bakdata/kafka/AvroMirrorTest.java | 0 .../src/test/java/com/bakdata/kafka/ConfiguratorTest.java | 0 .../java/com/bakdata/kafka/ConfiguredProducerAppTest.java | 0 .../test/java/com/bakdata/kafka/ConfiguredStreamsAppTest.java | 0 .../com/bakdata/kafka/EnvironmentStreamsConfigParserTest.java | 0 .../java/com/bakdata/kafka/ExecutableProducerAppTest.java | 0 .../test/java/com/bakdata/kafka/ExecutableStreamsAppTest.java | 0 .../src/test/java/com/bakdata/kafka/PreconfiguredTest.java | 0 .../test/java/com/bakdata/kafka/StreamsCleanUpRunnerTest.java | 0 .../java/com/bakdata/kafka/StreamsExecutionOptionsTest.java | 0 .../src/test/java/com/bakdata/kafka/TestUtil.java | 0 .../test/java/com/bakdata/kafka/integration/KafkaTest.java | 0 .../bakdata/kafka/integration/ProducerCleanUpRunnerTest.java | 0 .../com/bakdata/kafka/integration/ProducerRunnerTest.java | 0 .../bakdata/kafka/integration/StreamsCleanUpRunnerTest.java | 0 .../java/com/bakdata/kafka/integration/StreamsRunnerTest.java | 0 .../com/bakdata/kafka/test_applications/AvroKeyProducer.java | 0 .../bakdata/kafka/test_applications/AvroValueProducer.java | 0 .../kafka/test_applications/ComplexTopologyApplication.java | 0 .../com/bakdata/kafka/test_applications/ExtraInputTopics.java | 0 .../test/java/com/bakdata/kafka/test_applications/Mirror.java | 0 .../bakdata/kafka/test_applications/MirrorKeyWithAvro.java | 0 .../bakdata/kafka/test_applications/MirrorValueWithAvro.java | 0 .../kafka/test_applications/MirrorWithNonDefaultSerde.java | 0 .../com/bakdata/kafka/test_applications/StringProducer.java | 0 .../java/com/bakdata/kafka/test_applications/WordCount.java | 0 .../com/bakdata/kafka/test_applications/WordCountPattern.java | 0 .../java/com/bakdata/kafka/util/SchemaTopicClientTest.java | 0 .../src/test/java/com/bakdata/kafka/util/TopicClientTest.java | 0 .../java/com/bakdata/kafka/util/TopologyInformationTest.java | 0 .../src/test/resources/log4j2.xml | 0 streams-bootstrap-large-messages/build.gradle.kts | 2 +- streams-bootstrap-test/build.gradle.kts | 2 +- 112 files changed, 13 insertions(+), 13 deletions(-) rename {streams-bootstrap-picocli => streams-bootstrap-cli}/build.gradle.kts (97%) rename {streams-bootstrap-picocli => streams-bootstrap-cli}/src/main/java/com/bakdata/kafka/EnvironmentArgumentsParser.java (100%) rename {streams-bootstrap-picocli => streams-bootstrap-cli}/src/main/java/com/bakdata/kafka/KafkaApplication.java (100%) rename {streams-bootstrap-picocli => streams-bootstrap-cli}/src/main/java/com/bakdata/kafka/KafkaProducerApplication.java (100%) rename {streams-bootstrap-picocli => streams-bootstrap-cli}/src/main/java/com/bakdata/kafka/KafkaStreamsApplication.java (100%) rename {streams-bootstrap-picocli => streams-bootstrap-cli}/src/main/java/com/bakdata/kafka/SimpleKafkaProducerApplication.java (100%) rename {streams-bootstrap-picocli => streams-bootstrap-cli}/src/main/java/com/bakdata/kafka/SimpleKafkaStreamsApplication.java (100%) rename {streams-bootstrap-picocli => streams-bootstrap-cli}/src/main/java/com/bakdata/kafka/StringListConverter.java (100%) rename {streams-bootstrap-picocli => streams-bootstrap-cli}/src/test/avro/TestRecord.avsc (100%) rename {streams-bootstrap-picocli => streams-bootstrap-cli}/src/test/java/com/bakdata/kafka/CliTest.java (100%) rename {streams-bootstrap-picocli => streams-bootstrap-cli}/src/test/java/com/bakdata/kafka/CloseFlagApp.java (100%) rename {streams-bootstrap-picocli => streams-bootstrap-cli}/src/test/java/com/bakdata/kafka/EnvironmentArgumentsParserTest.java (100%) rename {streams-bootstrap-picocli => streams-bootstrap-cli}/src/test/java/com/bakdata/kafka/StringListConverterTest.java (100%) rename {streams-bootstrap-picocli => streams-bootstrap-cli}/src/test/java/com/bakdata/kafka/TestUtil.java (100%) rename {streams-bootstrap-picocli => streams-bootstrap-cli}/src/test/java/com/bakdata/kafka/integration/RunProducerAppTest.java (100%) rename {streams-bootstrap-picocli => streams-bootstrap-cli}/src/test/java/com/bakdata/kafka/integration/RunStreamsAppTest.java (100%) rename {streams-bootstrap-picocli => streams-bootstrap-cli}/src/test/java/com/bakdata/kafka/integration/StreamsCleanUpTest.java (100%) rename {streams-bootstrap-picocli => streams-bootstrap-cli}/src/test/java/com/bakdata/kafka/test_applications/Mirror.java (100%) rename {streams-bootstrap-picocli => streams-bootstrap-cli}/src/test/java/com/bakdata/kafka/test_applications/WordCount.java (100%) rename {streams-bootstrap-picocli => streams-bootstrap-cli}/src/test/resources/log4j2.xml (100%) rename {streams-bootstrap => streams-bootstrap-core}/build.gradle.kts (100%) rename {streams-bootstrap => streams-bootstrap-core}/lombok.config (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/App.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/AppConfiguration.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/CapturingStreamsUncaughtExceptionHandler.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/CleanUpException.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/CleanUpRunner.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/Configurable.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/ConfigurableSerde.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/ConfigurableSerializer.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/Configurator.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/ConfiguredApp.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/ConfiguredProducerApp.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/ConfiguredStreamsApp.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/DefaultConfigurable.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/DefaultStreamsUncaughtExceptionHandler.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/EffectiveAppConfiguration.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/EnvironmentStreamsConfigParser.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/ExecutableApp.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/ExecutableProducerApp.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/ExecutableStreamsApp.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/HasCleanHook.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/HasTopicHooks.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/ImprovedStreamsConfig.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/KafkaEndpointConfig.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/KafkaPropertiesFactory.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/NoOpStateListener.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/Preconfigured.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/ProducerApp.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/ProducerBuilder.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/ProducerCleanUpConfiguration.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/ProducerCleanUpRunner.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/ProducerExecutionOptions.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/ProducerRunnable.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/ProducerRunner.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/ProducerTopicConfig.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/Runner.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/StreamsApp.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/StreamsApplicationException.java (98%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/StreamsCleanUpConfiguration.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/StreamsCleanUpRunner.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/StreamsExecutionOptions.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/StreamsRunner.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/StreamsShutdownStateListener.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/StreamsTopicConfig.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/TopologyBuilder.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/util/ConsumerGroupClient.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/util/DirectTopicSubscription.java (98%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/util/ImprovedAdminClient.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/util/KafkaAdminException.java (97%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/util/PatternTopicSubscription.java (98%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/util/SchemaTopicClient.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/util/TopicClient.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/util/TopicSettings.java (97%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/util/TopicSubscription.java (98%) rename {streams-bootstrap => streams-bootstrap-core}/src/main/java/com/bakdata/kafka/util/TopologyInformation.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/avro/TestRecord.avsc (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/AvroMirrorTest.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/ConfiguratorTest.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/ConfiguredProducerAppTest.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/ConfiguredStreamsAppTest.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/EnvironmentStreamsConfigParserTest.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/ExecutableProducerAppTest.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/ExecutableStreamsAppTest.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/PreconfiguredTest.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/StreamsCleanUpRunnerTest.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/StreamsExecutionOptionsTest.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/TestUtil.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/integration/KafkaTest.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/integration/ProducerCleanUpRunnerTest.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/integration/ProducerRunnerTest.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/integration/StreamsCleanUpRunnerTest.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/integration/StreamsRunnerTest.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/test_applications/AvroKeyProducer.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/test_applications/AvroValueProducer.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/test_applications/ComplexTopologyApplication.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/test_applications/ExtraInputTopics.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/test_applications/Mirror.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/test_applications/MirrorKeyWithAvro.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/test_applications/MirrorValueWithAvro.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/test_applications/MirrorWithNonDefaultSerde.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/test_applications/StringProducer.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/test_applications/WordCount.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/test_applications/WordCountPattern.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/util/SchemaTopicClientTest.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/util/TopicClientTest.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/java/com/bakdata/kafka/util/TopologyInformationTest.java (100%) rename {streams-bootstrap => streams-bootstrap-core}/src/test/resources/log4j2.xml (100%) diff --git a/README.md b/README.md index 56e8170d..57ffe880 100644 --- 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: ' com.bakdata.kafka - streams-bootstrap + streams-bootstrap-cli 3.0.0 ``` diff --git a/settings.gradle b/settings.gradle index 1c6fbf13..e9057df9 100644 --- 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 b/streams-bootstrap-cli/build.gradle.kts similarity index 97% rename from streams-bootstrap-picocli/build.gradle.kts rename to streams-bootstrap-cli/build.gradle.kts index d18c6b8e..83eea817 100644 --- a/streams-bootstrap-picocli/build.gradle.kts +++ b/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/streams-bootstrap-picocli/src/main/java/com/bakdata/kafka/EnvironmentArgumentsParser.java b/streams-bootstrap-cli/src/main/java/com/bakdata/kafka/EnvironmentArgumentsParser.java similarity index 100% rename from streams-bootstrap-picocli/src/main/java/com/bakdata/kafka/EnvironmentArgumentsParser.java rename to streams-bootstrap-cli/src/main/java/com/bakdata/kafka/EnvironmentArgumentsParser.java diff --git a/streams-bootstrap-picocli/src/main/java/com/bakdata/kafka/KafkaApplication.java b/streams-bootstrap-cli/src/main/java/com/bakdata/kafka/KafkaApplication.java similarity index 100% rename from streams-bootstrap-picocli/src/main/java/com/bakdata/kafka/KafkaApplication.java rename to streams-bootstrap-cli/src/main/java/com/bakdata/kafka/KafkaApplication.java diff --git a/streams-bootstrap-picocli/src/main/java/com/bakdata/kafka/KafkaProducerApplication.java b/streams-bootstrap-cli/src/main/java/com/bakdata/kafka/KafkaProducerApplication.java similarity index 100% rename from streams-bootstrap-picocli/src/main/java/com/bakdata/kafka/KafkaProducerApplication.java rename to streams-bootstrap-cli/src/main/java/com/bakdata/kafka/KafkaProducerApplication.java diff --git a/streams-bootstrap-picocli/src/main/java/com/bakdata/kafka/KafkaStreamsApplication.java b/streams-bootstrap-cli/src/main/java/com/bakdata/kafka/KafkaStreamsApplication.java similarity index 100% rename from streams-bootstrap-picocli/src/main/java/com/bakdata/kafka/KafkaStreamsApplication.java rename to streams-bootstrap-cli/src/main/java/com/bakdata/kafka/KafkaStreamsApplication.java diff --git a/streams-bootstrap-picocli/src/main/java/com/bakdata/kafka/SimpleKafkaProducerApplication.java b/streams-bootstrap-cli/src/main/java/com/bakdata/kafka/SimpleKafkaProducerApplication.java similarity index 100% rename from streams-bootstrap-picocli/src/main/java/com/bakdata/kafka/SimpleKafkaProducerApplication.java rename to streams-bootstrap-cli/src/main/java/com/bakdata/kafka/SimpleKafkaProducerApplication.java diff --git a/streams-bootstrap-picocli/src/main/java/com/bakdata/kafka/SimpleKafkaStreamsApplication.java b/streams-bootstrap-cli/src/main/java/com/bakdata/kafka/SimpleKafkaStreamsApplication.java similarity index 100% rename from streams-bootstrap-picocli/src/main/java/com/bakdata/kafka/SimpleKafkaStreamsApplication.java rename to streams-bootstrap-cli/src/main/java/com/bakdata/kafka/SimpleKafkaStreamsApplication.java diff --git a/streams-bootstrap-picocli/src/main/java/com/bakdata/kafka/StringListConverter.java b/streams-bootstrap-cli/src/main/java/com/bakdata/kafka/StringListConverter.java similarity index 100% rename from streams-bootstrap-picocli/src/main/java/com/bakdata/kafka/StringListConverter.java rename to streams-bootstrap-cli/src/main/java/com/bakdata/kafka/StringListConverter.java diff --git a/streams-bootstrap-picocli/src/test/avro/TestRecord.avsc b/streams-bootstrap-cli/src/test/avro/TestRecord.avsc similarity index 100% rename from streams-bootstrap-picocli/src/test/avro/TestRecord.avsc rename to streams-bootstrap-cli/src/test/avro/TestRecord.avsc diff --git a/streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/CliTest.java b/streams-bootstrap-cli/src/test/java/com/bakdata/kafka/CliTest.java similarity index 100% rename from streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/CliTest.java rename to streams-bootstrap-cli/src/test/java/com/bakdata/kafka/CliTest.java diff --git a/streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/CloseFlagApp.java b/streams-bootstrap-cli/src/test/java/com/bakdata/kafka/CloseFlagApp.java similarity index 100% rename from streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/CloseFlagApp.java rename to streams-bootstrap-cli/src/test/java/com/bakdata/kafka/CloseFlagApp.java diff --git a/streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/EnvironmentArgumentsParserTest.java b/streams-bootstrap-cli/src/test/java/com/bakdata/kafka/EnvironmentArgumentsParserTest.java similarity index 100% rename from streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/EnvironmentArgumentsParserTest.java rename to streams-bootstrap-cli/src/test/java/com/bakdata/kafka/EnvironmentArgumentsParserTest.java diff --git a/streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/StringListConverterTest.java b/streams-bootstrap-cli/src/test/java/com/bakdata/kafka/StringListConverterTest.java similarity index 100% rename from streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/StringListConverterTest.java rename to streams-bootstrap-cli/src/test/java/com/bakdata/kafka/StringListConverterTest.java diff --git a/streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/TestUtil.java b/streams-bootstrap-cli/src/test/java/com/bakdata/kafka/TestUtil.java similarity index 100% rename from streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/TestUtil.java rename to streams-bootstrap-cli/src/test/java/com/bakdata/kafka/TestUtil.java diff --git a/streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/integration/RunProducerAppTest.java b/streams-bootstrap-cli/src/test/java/com/bakdata/kafka/integration/RunProducerAppTest.java similarity index 100% rename from streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/integration/RunProducerAppTest.java rename to streams-bootstrap-cli/src/test/java/com/bakdata/kafka/integration/RunProducerAppTest.java diff --git a/streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/integration/RunStreamsAppTest.java b/streams-bootstrap-cli/src/test/java/com/bakdata/kafka/integration/RunStreamsAppTest.java similarity index 100% rename from streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/integration/RunStreamsAppTest.java rename to streams-bootstrap-cli/src/test/java/com/bakdata/kafka/integration/RunStreamsAppTest.java diff --git a/streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/integration/StreamsCleanUpTest.java b/streams-bootstrap-cli/src/test/java/com/bakdata/kafka/integration/StreamsCleanUpTest.java similarity index 100% rename from streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/integration/StreamsCleanUpTest.java rename to streams-bootstrap-cli/src/test/java/com/bakdata/kafka/integration/StreamsCleanUpTest.java diff --git a/streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/test_applications/Mirror.java b/streams-bootstrap-cli/src/test/java/com/bakdata/kafka/test_applications/Mirror.java similarity index 100% rename from streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/test_applications/Mirror.java rename to streams-bootstrap-cli/src/test/java/com/bakdata/kafka/test_applications/Mirror.java diff --git a/streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/test_applications/WordCount.java b/streams-bootstrap-cli/src/test/java/com/bakdata/kafka/test_applications/WordCount.java similarity index 100% rename from streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/test_applications/WordCount.java rename to streams-bootstrap-cli/src/test/java/com/bakdata/kafka/test_applications/WordCount.java diff --git a/streams-bootstrap-picocli/src/test/resources/log4j2.xml b/streams-bootstrap-cli/src/test/resources/log4j2.xml similarity index 100% rename from streams-bootstrap-picocli/src/test/resources/log4j2.xml rename to streams-bootstrap-cli/src/test/resources/log4j2.xml diff --git a/streams-bootstrap/build.gradle.kts b/streams-bootstrap-core/build.gradle.kts similarity index 100% rename from streams-bootstrap/build.gradle.kts rename to streams-bootstrap-core/build.gradle.kts diff --git a/streams-bootstrap/lombok.config b/streams-bootstrap-core/lombok.config similarity index 100% rename from streams-bootstrap/lombok.config rename to streams-bootstrap-core/lombok.config diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/App.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/App.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/App.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/App.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/AppConfiguration.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/AppConfiguration.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/AppConfiguration.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/AppConfiguration.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/CapturingStreamsUncaughtExceptionHandler.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/CapturingStreamsUncaughtExceptionHandler.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/CapturingStreamsUncaughtExceptionHandler.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/CapturingStreamsUncaughtExceptionHandler.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/CleanUpException.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/CleanUpException.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/CleanUpException.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/CleanUpException.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/CleanUpRunner.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/CleanUpRunner.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/CleanUpRunner.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/CleanUpRunner.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/Configurable.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/Configurable.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/Configurable.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/Configurable.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/ConfigurableSerde.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/ConfigurableSerde.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/ConfigurableSerde.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/ConfigurableSerde.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/ConfigurableSerializer.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/ConfigurableSerializer.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/ConfigurableSerializer.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/ConfigurableSerializer.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/Configurator.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/Configurator.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/Configurator.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/Configurator.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/ConfiguredApp.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/ConfiguredApp.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/ConfiguredApp.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/ConfiguredApp.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/ConfiguredProducerApp.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/ConfiguredProducerApp.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/ConfiguredProducerApp.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/ConfiguredProducerApp.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/ConfiguredStreamsApp.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/ConfiguredStreamsApp.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/ConfiguredStreamsApp.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/ConfiguredStreamsApp.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/DefaultConfigurable.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/DefaultConfigurable.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/DefaultConfigurable.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/DefaultConfigurable.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/DefaultStreamsUncaughtExceptionHandler.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/DefaultStreamsUncaughtExceptionHandler.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/DefaultStreamsUncaughtExceptionHandler.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/DefaultStreamsUncaughtExceptionHandler.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/EffectiveAppConfiguration.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/EffectiveAppConfiguration.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/EffectiveAppConfiguration.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/EffectiveAppConfiguration.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/EnvironmentStreamsConfigParser.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/EnvironmentStreamsConfigParser.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/EnvironmentStreamsConfigParser.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/EnvironmentStreamsConfigParser.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/ExecutableApp.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/ExecutableApp.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/ExecutableApp.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/ExecutableApp.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/ExecutableProducerApp.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/ExecutableProducerApp.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/ExecutableProducerApp.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/ExecutableProducerApp.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/ExecutableStreamsApp.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/ExecutableStreamsApp.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/ExecutableStreamsApp.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/ExecutableStreamsApp.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/HasCleanHook.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/HasCleanHook.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/HasCleanHook.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/HasCleanHook.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/HasTopicHooks.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/HasTopicHooks.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/HasTopicHooks.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/HasTopicHooks.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/ImprovedStreamsConfig.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/ImprovedStreamsConfig.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/ImprovedStreamsConfig.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/ImprovedStreamsConfig.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/KafkaEndpointConfig.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/KafkaEndpointConfig.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/KafkaEndpointConfig.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/KafkaEndpointConfig.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/KafkaPropertiesFactory.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/KafkaPropertiesFactory.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/KafkaPropertiesFactory.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/KafkaPropertiesFactory.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/NoOpStateListener.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/NoOpStateListener.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/NoOpStateListener.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/NoOpStateListener.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/Preconfigured.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/Preconfigured.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/Preconfigured.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/Preconfigured.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/ProducerApp.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/ProducerApp.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/ProducerApp.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/ProducerApp.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/ProducerBuilder.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/ProducerBuilder.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/ProducerBuilder.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/ProducerBuilder.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/ProducerCleanUpConfiguration.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/ProducerCleanUpConfiguration.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/ProducerCleanUpConfiguration.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/ProducerCleanUpConfiguration.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/ProducerCleanUpRunner.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/ProducerCleanUpRunner.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/ProducerCleanUpRunner.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/ProducerCleanUpRunner.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/ProducerExecutionOptions.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/ProducerExecutionOptions.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/ProducerExecutionOptions.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/ProducerExecutionOptions.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/ProducerRunnable.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/ProducerRunnable.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/ProducerRunnable.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/ProducerRunnable.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/ProducerRunner.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/ProducerRunner.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/ProducerRunner.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/ProducerRunner.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/ProducerTopicConfig.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/ProducerTopicConfig.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/ProducerTopicConfig.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/ProducerTopicConfig.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/Runner.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/Runner.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/Runner.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/Runner.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/StreamsApp.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsApp.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/StreamsApp.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsApp.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/StreamsApplicationException.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsApplicationException.java similarity index 98% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/StreamsApplicationException.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsApplicationException.java index 6073e048..058bddcb 100644 --- a/streams-bootstrap/src/main/java/com/bakdata/kafka/StreamsApplicationException.java +++ b/streams-bootstrap-core/src/main/java/com/bakdata/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/streams-bootstrap/src/main/java/com/bakdata/kafka/StreamsCleanUpConfiguration.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsCleanUpConfiguration.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/StreamsCleanUpConfiguration.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsCleanUpConfiguration.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/StreamsCleanUpRunner.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsCleanUpRunner.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/StreamsCleanUpRunner.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsCleanUpRunner.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/StreamsExecutionOptions.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsExecutionOptions.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/StreamsExecutionOptions.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsExecutionOptions.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/StreamsRunner.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsRunner.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/StreamsRunner.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsRunner.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/StreamsShutdownStateListener.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsShutdownStateListener.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/StreamsShutdownStateListener.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsShutdownStateListener.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/StreamsTopicConfig.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsTopicConfig.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/StreamsTopicConfig.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsTopicConfig.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/TopologyBuilder.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/TopologyBuilder.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/TopologyBuilder.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/TopologyBuilder.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/util/ConsumerGroupClient.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/util/ConsumerGroupClient.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/util/ConsumerGroupClient.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/util/ConsumerGroupClient.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/util/DirectTopicSubscription.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/util/DirectTopicSubscription.java similarity index 98% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/util/DirectTopicSubscription.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/util/DirectTopicSubscription.java index 7c7a0c18..06e4e150 100644 --- a/streams-bootstrap/src/main/java/com/bakdata/kafka/util/DirectTopicSubscription.java +++ b/streams-bootstrap-core/src/main/java/com/bakdata/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/streams-bootstrap/src/main/java/com/bakdata/kafka/util/ImprovedAdminClient.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/util/ImprovedAdminClient.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/util/ImprovedAdminClient.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/util/ImprovedAdminClient.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/util/KafkaAdminException.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/util/KafkaAdminException.java similarity index 97% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/util/KafkaAdminException.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/util/KafkaAdminException.java index f363b76e..b1a5d6f9 100644 --- a/streams-bootstrap/src/main/java/com/bakdata/kafka/util/KafkaAdminException.java +++ b/streams-bootstrap-core/src/main/java/com/bakdata/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/streams-bootstrap/src/main/java/com/bakdata/kafka/util/PatternTopicSubscription.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/util/PatternTopicSubscription.java similarity index 98% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/util/PatternTopicSubscription.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/util/PatternTopicSubscription.java index 7fd0286f..5de2db60 100644 --- a/streams-bootstrap/src/main/java/com/bakdata/kafka/util/PatternTopicSubscription.java +++ b/streams-bootstrap-core/src/main/java/com/bakdata/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/streams-bootstrap/src/main/java/com/bakdata/kafka/util/SchemaTopicClient.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/util/SchemaTopicClient.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/util/SchemaTopicClient.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/util/SchemaTopicClient.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/util/TopicClient.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/util/TopicClient.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/util/TopicClient.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/util/TopicClient.java diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/util/TopicSettings.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/util/TopicSettings.java similarity index 97% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/util/TopicSettings.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/util/TopicSettings.java index 61af845c..329adf1f 100644 --- a/streams-bootstrap/src/main/java/com/bakdata/kafka/util/TopicSettings.java +++ b/streams-bootstrap-core/src/main/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/streams-bootstrap/src/main/java/com/bakdata/kafka/util/TopicSubscription.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/util/TopicSubscription.java similarity index 98% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/util/TopicSubscription.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/util/TopicSubscription.java index ec519691..8235cbe8 100644 --- a/streams-bootstrap/src/main/java/com/bakdata/kafka/util/TopicSubscription.java +++ b/streams-bootstrap-core/src/main/java/com/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/streams-bootstrap/src/main/java/com/bakdata/kafka/util/TopologyInformation.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/util/TopologyInformation.java similarity index 100% rename from streams-bootstrap/src/main/java/com/bakdata/kafka/util/TopologyInformation.java rename to streams-bootstrap-core/src/main/java/com/bakdata/kafka/util/TopologyInformation.java diff --git a/streams-bootstrap/src/test/avro/TestRecord.avsc b/streams-bootstrap-core/src/test/avro/TestRecord.avsc similarity index 100% rename from streams-bootstrap/src/test/avro/TestRecord.avsc rename to streams-bootstrap-core/src/test/avro/TestRecord.avsc diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/AvroMirrorTest.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/AvroMirrorTest.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/AvroMirrorTest.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/AvroMirrorTest.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/ConfiguratorTest.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/ConfiguratorTest.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/ConfiguratorTest.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/ConfiguratorTest.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/ConfiguredProducerAppTest.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/ConfiguredProducerAppTest.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/ConfiguredProducerAppTest.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/ConfiguredProducerAppTest.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/ConfiguredStreamsAppTest.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/ConfiguredStreamsAppTest.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/ConfiguredStreamsAppTest.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/ConfiguredStreamsAppTest.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/EnvironmentStreamsConfigParserTest.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/EnvironmentStreamsConfigParserTest.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/EnvironmentStreamsConfigParserTest.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/EnvironmentStreamsConfigParserTest.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/ExecutableProducerAppTest.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/ExecutableProducerAppTest.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/ExecutableProducerAppTest.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/ExecutableProducerAppTest.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/ExecutableStreamsAppTest.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/ExecutableStreamsAppTest.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/ExecutableStreamsAppTest.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/ExecutableStreamsAppTest.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/PreconfiguredTest.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/PreconfiguredTest.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/PreconfiguredTest.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/PreconfiguredTest.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/StreamsCleanUpRunnerTest.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/StreamsCleanUpRunnerTest.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/StreamsCleanUpRunnerTest.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/StreamsCleanUpRunnerTest.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/StreamsExecutionOptionsTest.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/StreamsExecutionOptionsTest.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/StreamsExecutionOptionsTest.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/StreamsExecutionOptionsTest.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/TestUtil.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/TestUtil.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/TestUtil.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/TestUtil.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/integration/KafkaTest.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/integration/KafkaTest.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/integration/KafkaTest.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/integration/KafkaTest.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/integration/ProducerCleanUpRunnerTest.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/integration/ProducerCleanUpRunnerTest.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/integration/ProducerCleanUpRunnerTest.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/integration/ProducerCleanUpRunnerTest.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/integration/ProducerRunnerTest.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/integration/ProducerRunnerTest.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/integration/ProducerRunnerTest.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/integration/ProducerRunnerTest.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/integration/StreamsCleanUpRunnerTest.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/integration/StreamsCleanUpRunnerTest.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/integration/StreamsCleanUpRunnerTest.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/integration/StreamsCleanUpRunnerTest.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/integration/StreamsRunnerTest.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/integration/StreamsRunnerTest.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/integration/StreamsRunnerTest.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/integration/StreamsRunnerTest.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/test_applications/AvroKeyProducer.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/test_applications/AvroKeyProducer.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/test_applications/AvroKeyProducer.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/test_applications/AvroKeyProducer.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/test_applications/AvroValueProducer.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/test_applications/AvroValueProducer.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/test_applications/AvroValueProducer.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/test_applications/AvroValueProducer.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/test_applications/ComplexTopologyApplication.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/test_applications/ComplexTopologyApplication.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/test_applications/ComplexTopologyApplication.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/test_applications/ComplexTopologyApplication.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/test_applications/ExtraInputTopics.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/test_applications/ExtraInputTopics.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/test_applications/ExtraInputTopics.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/test_applications/ExtraInputTopics.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/test_applications/Mirror.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/test_applications/Mirror.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/test_applications/Mirror.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/test_applications/Mirror.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/test_applications/MirrorKeyWithAvro.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/test_applications/MirrorKeyWithAvro.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/test_applications/MirrorKeyWithAvro.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/test_applications/MirrorKeyWithAvro.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/test_applications/MirrorValueWithAvro.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/test_applications/MirrorValueWithAvro.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/test_applications/MirrorValueWithAvro.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/test_applications/MirrorValueWithAvro.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/test_applications/MirrorWithNonDefaultSerde.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/test_applications/MirrorWithNonDefaultSerde.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/test_applications/MirrorWithNonDefaultSerde.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/test_applications/MirrorWithNonDefaultSerde.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/test_applications/StringProducer.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/test_applications/StringProducer.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/test_applications/StringProducer.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/test_applications/StringProducer.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/test_applications/WordCount.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/test_applications/WordCount.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/test_applications/WordCount.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/test_applications/WordCount.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/test_applications/WordCountPattern.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/test_applications/WordCountPattern.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/test_applications/WordCountPattern.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/test_applications/WordCountPattern.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/util/SchemaTopicClientTest.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/util/SchemaTopicClientTest.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/util/SchemaTopicClientTest.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/util/SchemaTopicClientTest.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/util/TopicClientTest.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/util/TopicClientTest.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/util/TopicClientTest.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/util/TopicClientTest.java diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/util/TopologyInformationTest.java b/streams-bootstrap-core/src/test/java/com/bakdata/kafka/util/TopologyInformationTest.java similarity index 100% rename from streams-bootstrap/src/test/java/com/bakdata/kafka/util/TopologyInformationTest.java rename to streams-bootstrap-core/src/test/java/com/bakdata/kafka/util/TopologyInformationTest.java diff --git a/streams-bootstrap/src/test/resources/log4j2.xml b/streams-bootstrap-core/src/test/resources/log4j2.xml similarity index 100% rename from streams-bootstrap/src/test/resources/log4j2.xml rename to streams-bootstrap-core/src/test/resources/log4j2.xml diff --git a/streams-bootstrap-large-messages/build.gradle.kts b/streams-bootstrap-large-messages/build.gradle.kts index 0bf48f77..8b75b2a2 100644 --- 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 index 43684367..99a47667 100644 --- 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",