- Mar 16, 2021
-
-
Sören Henning authored
-
- Mar 14, 2021
-
-
Björn Vonheiden authored
-
- Mar 12, 2021
-
-
Björn Vonheiden authored
Extract the kafka streams and flink use case and load generator and commons dependencies to a convention plugin to reduce the complexety of the main build gradle file.
-
Björn Vonheiden authored
Create convention plugins to reduce complexity of the root build.gradle file
-
- Mar 09, 2021
-
-
Sören Henning authored
-
Sören Henning authored
-
Sören Henning authored
-
- Mar 08, 2021
-
-
Sören Henning authored
-
Sören Henning authored
-
Sören Henning authored
Co-authored-by:
Nico Biernat <stu209212@mail.uni-kiel.de>
-
- Mar 05, 2021
-
-
Sören Henning authored
-
- Mar 01, 2021
-
-
Sören Henning authored
-
- Dec 07, 2020
-
-
Sören Henning authored
-
- Nov 28, 2020
-
-
Björn Vonheiden authored
Configure the Kafka Streams configuration in a common class and not add them in every UC application. This enhances maintainability of common shared configurations. Further enable more configurations to set for the Kafka Streams application.
-
- Nov 27, 2020
-
-
Björn Vonheiden authored
-
Björn Vonheiden authored
Update spotbugs plugin.
-
- Aug 24, 2020
-
-
Björn Vonheiden authored
-Use aggregation from titan with dataflow -Add an aggregation-feedback topic -Enable logging in UC2 with new slf4j version -Use newer Kafkastreams version -Remove unused ConfigurationKeys class
-
- Jul 26, 2020
-
-
Björn Vonheiden authored
Replace the kieker records with the avro records from titan. Further use the builder pattern in the KafkaRecordSender to enable creation with different parameters.
-
Björn Vonheiden authored
Due to the merge the project was not possible to build with gradle. Because both projects changed the gradle build file some properties were not added to the correct places in the file. Further in one configuration class the same property existed twice. diff --git a/application-kafkastreams-commons/src/main/java/theodolite/commons/kafkastreams/ConfigurationKeys.java b/application-kafkastreams-commons/src/main/java/theodolite/commons/kafkastreams/ConfigurationKeys.java index 61fb135..260dbba 100644 --- a/application-kafkastreams-commons/src/main/java/theodolite/commons/kafkastreams/ConfigurationKeys.java +++ b/application-kafkastreams-commons/src/main/java/theodolite/commons/kafkastreams/ConfigurationKeys.java @@ -15,10 +15,6 @@ public final class ConfigurationKeys { public static final String CACHE_MAX_BYTES_BUFFERING = "cache.max.bytes.buffering"; - public static final String APPLICATION_NAME = "application.name"; - - public static final String APPLICATION_VERSION = "application.version"; - public static final String KAFKA_BOOTSTRAP_SERVERS = "kafka.bootstrap.servers"; public static final String SCHEMA_REGISTRY_URL = "schema.registry.url"; diff --git a/build.gradle b/build.gradle index 1caf1b6..797d103 100644 --- a/build.gradle +++ b/build.gradle @@ -69,9 +69,6 @@ configure(useCaseApplications) { implementation 'org.slf4j:slf4j-simple:1.6.1' implementation project(':application-kafkastreams-commons') - // These dependencies are used for the workload-generator-commmon - implementation project(':workload-generator-commons') - // Use JUnit test framework testImplementation 'junit:junit:4.12' } @@ -82,10 +79,13 @@ configure(useCaseGenerators) { dependencies { // These dependencies are used internally, and not exposed to consumers on their own compile classpath. // implementation('org.industrial-devops:titan-ccp-common:0.1.0-SNAPSHOT') { changing = true } - implementation('org.industrial-devops:titan-ccp-common-kafka:0.1.0-SNAPSHOT') { changing = true } + // implementation('org.industrial-devops:titan-ccp-common-kafka:0.1.0-SNAPSHOT') { changing = true } implementation 'com.google.guava:guava:24.1-jre' implementation 'org.jctools:jctools-core:2.1.1' implementation 'org.slf4j:slf4j-simple:1.6.1' + + // These dependencies are used for the workload-generator-commmon + implementation project(':workload-generator-commons') // maintain build of generators implementation 'net.kieker-monitoring:kieker:1.14' @@ -102,12 +102,12 @@ configure(commonProjects) { // These dependencies is exported to consumers, that is to say found on their compile classpath. api 'org.apache.kafka:kafka-clients:2.4.0' api('org.industrial-devops:titan-ccp-common:0.0.3-SNAPSHOT') { changing = true } - api 'net.kieker-monitoring:kieker:1.14-SNAPSHOT' + api 'net.kieker-monitoring:kieker:1.14' // These dependencies are used internally, and not exposed to consumers on their own compile classpath. implementation 'org.slf4j:slf4j-simple:1.6.1' - implementation('org.industrial-devops:titan-ccp-common:0.1.0-SNAPSHOT') { changing = true } - implementation('org.industrial-devops:titan-ccp-common-kafka:0.1.0-SNAPSHOT') { changing = true } + // implementation('org.industrial-devops:titan-ccp-common:0.1.0-SNAPSHOT') { changing = true } + // implementation('org.industrial-devops:titan-ccp-common-kafka:0.1.0-SNAPSHOT') { changing = true } // Use JUnit test framework testImplementation 'junit:junit:4.12'
-
- Jul 21, 2020
-
-
Sören Henning authored
-
- Jun 07, 2020
-
-
Simon Ehrenstein authored
-
- Jun 02, 2020
-
-
Simon Ehrenstein authored
-
- May 30, 2020
-
-
Björn Vonheiden authored
Replace the kieker records for reading and writing to/from kafka with the avro records from Titan.
-
- May 18, 2020
-
-
Simon Ehrenstein authored
-
- May 14, 2020
-
-
Björn Vonheiden authored
- Define variables for commons projects and uc projects - Add different dependencies to the different subprojects - Apply application plugin only to ucs - allow uc to use the commons project as dependency diff --git a/build.gradle b/build.gradle index 6827860..694a127 100644 --- a/build.gradle +++ b/build.gradle @@ -10,20 +10,27 @@ buildscript { } } -// Plugins for all projects +// Variables used to distinct different subprojects +def useCaseProjects = subprojects.findAll {it -> it.name.matches('uc(.)*')} +def commonProjects = subprojects.findAll {it -> it.name.matches('(.)*commons(.)*')} + + +// Plugins allprojects { apply plugin: 'eclipse' } -// Plugins for subprojects subprojects { - apply plugin: 'application' apply plugin: 'checkstyle' apply plugin: 'pmd' apply plugin: 'com.github.spotbugs' apply plugin: 'java-library' } +configure(useCaseProjects){ + apply plugin: 'application' +} + // Java version for all subprojects subprojects { java { @@ -47,8 +54,8 @@ allprojects { } } -// Dependencies -subprojects { +// Dependencies for all use cases +configure(useCaseProjects) { dependencies { // These dependencies is exported to consumers, that is to say found on their compile classpath. api('org.industrial-devops:titan-ccp-common:0.0.3-SNAPSHOT') { changing = true } @@ -60,6 +67,22 @@ subprojects { implementation 'com.google.guava:guava:24.1-jre' implementation 'org.jctools:jctools-core:2.1.1' implementation 'org.slf4j:slf4j-simple:1.6.1' + implementation project(':application-kafkastreams-commons') + + // Use JUnit test framework + testImplementation 'junit:junit:4.12' + } +} + +// Dependencies for all commons +configure(commonProjects) { + dependencies { + // These dependencies is exported to consumers, that is to say found on their compile classpath. + api 'org.apache.kafka:kafka-clients:2.4.0' + + // These dependencies are used internally, and not exposed to consumers on their own compile classpath. + implementation 'org.slf4j:slf4j-simple:1.6.1' + implementation('org.industrial-devops:titan-ccp-common:0.0.3-SNAPSHOT') { changing = true } // Use JUnit test framework testImplementation 'junit:junit:4.12'
-
Björn Vonheiden authored
-
- May 13, 2020
-
-
Björn Vonheiden authored
-
Björn Vonheiden authored
Enables the execution of the code quality tools in the subprojects and configures them in a central place.
-
Björn Vonheiden authored
-
Björn Vonheiden authored
-
Björn Vonheiden authored
-
- Mar 26, 2020
-
-
Sören Henning authored
-
- Mar 13, 2020
-
-
Sören Henning authored
-