Generalize KafkaPropertiesBuilder
Add a common class for building kafka properties Add commit offset option in order to provide lag information
Showing
- theodolite-benchmarks/hazelcastjet-commons/src/main/java/rocks/theodolite/benchmarks/commons/hazelcastjet/KafkaPropertiesBuilder.java 88 additions, 0 deletions...nchmarks/commons/hazelcastjet/KafkaPropertiesBuilder.java
- theodolite-benchmarks/uc1-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc1/hazelcastjet/HistoryService.java 1 addition, 1 deletion...heodolite/benchmarks/uc1/hazelcastjet/HistoryService.java
- theodolite-benchmarks/uc1-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc1/hazelcastjet/Uc1HazelcastJetFactory.java 11 additions, 4 deletions...e/benchmarks/uc1/hazelcastjet/Uc1HazelcastJetFactory.java
- theodolite-benchmarks/uc1-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc1/hazelcastjet/Uc1KafkaPropertiesBuilder.java 1 addition, 1 deletion...enchmarks/uc1/hazelcastjet/Uc1KafkaPropertiesBuilder.java
- theodolite-benchmarks/uc2-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc2/hazelcastjet/HistoryService.java 2 additions, 2 deletions...heodolite/benchmarks/uc2/hazelcastjet/HistoryService.java
- theodolite-benchmarks/uc2-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc2/hazelcastjet/Uc2HazelcastJetFactory.java 19 additions, 8 deletions...e/benchmarks/uc2/hazelcastjet/Uc2HazelcastJetFactory.java
- theodolite-benchmarks/uc3-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc3/hazelcastjet/HistoryService.java 2 additions, 2 deletions...heodolite/benchmarks/uc3/hazelcastjet/HistoryService.java
- theodolite-benchmarks/uc3-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc3/hazelcastjet/Uc3HazelcastJetFactory.java 19 additions, 8 deletions...e/benchmarks/uc3/hazelcastjet/Uc3HazelcastJetFactory.java
- theodolite-benchmarks/uc4-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc4/hazelcastjet/HistoryService.java 1 addition, 1 deletion...heodolite/benchmarks/uc4/hazelcastjet/HistoryService.java
- theodolite-benchmarks/uc4-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc4/hazelcastjet/Uc4HazelcastJetFactory.java 29 additions, 13 deletions...e/benchmarks/uc4/hazelcastjet/Uc4HazelcastJetFactory.java
Loading
Please register or sign in to comment