-
- Downloads
final version
Showing
- .idea/workspace.xml 396 additions, 265 deletions.idea/workspace.xml
- README.md 9 additions, 7 deletionsREADME.md
- pom.xml 0 additions, 10 deletionspom.xml
- src/main/java/fr/ippon/kafkaLatency/model/Person.java 14 additions, 12 deletionssrc/main/java/fr/ippon/kafkaLatency/model/Person.java
- src/main/java/fr/ippon/kafkaLatency/producer/AlimKafkaAsync.java 128 additions, 123 deletions...n/java/fr/ippon/kafkaLatency/producer/AlimKafkaAsync.java
- src/main/java/fr/ippon/kafkaLatency/producer/AlimKafkaSync.java 129 additions, 129 deletions...in/java/fr/ippon/kafkaLatency/producer/AlimKafkaSync.java
- src/main/java/fr/ippon/kafkaLatency/streaming/KafkaContinuousSpark.java 23 additions, 27 deletions...fr/ippon/kafkaLatency/streaming/KafkaContinuousSpark.java
- src/main/java/fr/ippon/kafkaLatency/streaming/KafkaFlink.java 8 additions, 10 deletions...main/java/fr/ippon/kafkaLatency/streaming/KafkaFlink.java
- src/main/java/fr/ippon/kafkaLatency/streaming/KafkaSparkStreaming.java 18 additions, 18 deletions.../fr/ippon/kafkaLatency/streaming/KafkaSparkStreaming.java
- src/main/java/fr/ippon/kafkaLatency/streaming/KafkaStream.java 23 additions, 30 deletions...ain/java/fr/ippon/kafkaLatency/streaming/KafkaStream.java
- src/main/java/fr/ippon/kafkaLatency/streaming/KafkaStructuredSpark.java 9 additions, 9 deletions...fr/ippon/kafkaLatency/streaming/KafkaStructuredSpark.java
- src/main/java/fr/ippon/kafkaLatency/utils/Config.java 8 additions, 8 deletionssrc/main/java/fr/ippon/kafkaLatency/utils/Config.java
- src/main/java/fr/ippon/kafkaLatency/utils/UtilStats.java 25 additions, 25 deletionssrc/main/java/fr/ippon/kafkaLatency/utils/UtilStats.java
- src/main/resources/config.properties 3 additions, 6 deletionssrc/main/resources/config.properties
- src/main/resources/log4j.xml 17 additions, 7 deletionssrc/main/resources/log4j.xml
- target/classes/config.properties 4 additions, 5 deletionstarget/classes/config.properties
- target/classes/fr/ippon/kafkaLatency/AlimKafka$1.class 0 additions, 0 deletionstarget/classes/fr/ippon/kafkaLatency/AlimKafka$1.class
- target/classes/fr/ippon/kafkaLatency/AlimKafka.class 0 additions, 0 deletionstarget/classes/fr/ippon/kafkaLatency/AlimKafka.class
- target/classes/fr/ippon/kafkaLatency/AlimKafkaOptim.class 0 additions, 0 deletionstarget/classes/fr/ippon/kafkaLatency/AlimKafkaOptim.class
- target/classes/fr/ippon/kafkaLatency/streaming/KafkaContinuousSpark.class 0 additions, 0 deletions...r/ippon/kafkaLatency/streaming/KafkaContinuousSpark.class
Loading
Please register or sign in to comment