- 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
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'
-
- May 30, 2020
-
-
Björn Vonheiden authored
Replace the kieker records with the avro records in uc3 application.
-
Björn Vonheiden authored
In order to not add a new configuration key that is needed by all the kafka stream use case applications extract the configuration keys to the kafkastreams common project.
-
Björn Vonheiden authored
To allow using the schema registry kafka streams builder takes an URL for using late the avor schema regitstry factory.
-
- May 27, 2020
-
-
Björn Vonheiden authored
The Project is renamed to theodolite and therefore all packages should be renamed likewise.
-
Björn Vonheiden authored
-
- May 14, 2020
-
-
Björn Vonheiden authored
This allows the usecases to create its own Properties object if needed.
-
Björn Vonheiden authored
Create an abstract KafkaStreamsBuilder class that can be used in kafka streams use cases. This should reduce the redundancy for reconfigure the properties in every streams application. Now only the topology needs to be defined by the use cases.
-
Björn Vonheiden authored
- Added application-kafkastreams-common project - modified root gradle project - configure eclipse quality tools and formatting
-