diff --git a/README.md b/README.md index 47581e1c97fce5f0b4cea47801b8f32e5c6db344..ba169ef4f9be9ba29291d72051f05a294b74e794 100644 --- a/README.md +++ b/README.md @@ -2,33 +2,33 @@ Mesure latency between record insertion in Kafka and Streaming processing using Kafka automated timestamp of messages. -##Frameworks tested +## Frameworks tested - Kafka Stream - Flink - Spark (streaming, Structured Streaming and Continuous Processing -##Versions +## Versions - Spark : 2.3.0 - Flink : 1.4.2 - Kafka : 0.11.0.2 -##Sources -###Producer +## Sources +### Producer - fr.ippon.kafkaLatency.AlimKafka : Kafka Producer (100 000 messages) -###Consummer +### Consummer fr.ippon.kafkaLatency.streaming.KafkaSpark : Spark streaming consummer fr.ippon.kafkaLatency.streaming.KafkaStructuredSpark : Spark Structured streaming consummer fr.ippon.kafkaLatency.streaming.KafkaContinuousSpark : Spark Continous processing consummer fr.ippon.kafkaLatency.streaming.KafkaStreaming : Kafka Streams consummer fr.ippon.kafkaLatency.streaming.KafkaFlink : Flink consummer -###Utils +### Utils fr.ippon.kafkaLatency.utils.UtilStats : Streaming statistics fr.ippon.kafkaLatency.utils.MetricsProducerReporter : Kafka Producer Metrics -##Resources -###config.properties : +## Resources +### config.properties : - Kafka - topic : Kafka topic name to use - numPartitions : Number of partitions for topic