Skip to content
Snippets Groups Projects
Commit 25c52595 authored by Christophe PARAGEAUD's avatar Christophe PARAGEAUD
Browse files

Update formating

parent 4574f6e8
No related branches found
No related tags found
No related merge requests found
......@@ -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
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment