Skip to content
Snippets Groups Projects
  1. Sep 03, 2020
  2. Aug 24, 2020
  3. Aug 23, 2020
    • Björn Vonheiden's avatar
      Fix uc2 not sending output · 9e0f3ef2
      Björn Vonheiden authored
      Because of suppress and a compute intensive log in the stream
      application the use case may not produce any output.
      Further a log message is added for every computed aggregation.
      9e0f3ef2
  4. Jul 31, 2020
  5. Jul 29, 2020
  6. Jul 28, 2020
  7. Jul 27, 2020
  8. Jul 26, 2020
    • Björn Vonheiden's avatar
      Use the changed KafkaRecordSender in the workload generators. · 1d3a979f
      Björn Vonheiden authored
      Send avro data with the producer to kafka.
      1d3a979f
    • Björn Vonheiden's avatar
      Use Avro instead of kieker records in Workload Generator. · f8427109
      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.
      f8427109
    • Björn Vonheiden's avatar
      Abstract functional Transport interface from workload generator. · 67423b5f
      Björn Vonheiden authored
      Abstract the Interface to be more generic.
      67423b5f
    • Björn Vonheiden's avatar
      Fix gradle dependencies and duplicate property in class to enable build. · 74995017
      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'
      74995017
    • Björn Vonheiden's avatar
    • Björn Vonheiden's avatar
      Merge remote-tracking branch 'simon/1-first-version-of-workload-generator'... · 2fb84b68
      Björn Vonheiden authored
      Merge remote-tracking branch 'simon/1-first-version-of-workload-generator' into feature/app-wg-with-avro
      2fb84b68
  9. Jul 22, 2020
Loading