Home

Jump to bottom

Vaquar Khan edited this page Jan 3, 2017 · 5 revisions

Need to updated Kafka client to 0.10

Update VM param

 -Xms128m -Xmx512m -XX:MaxPermSize=300m -ea

Spark 2.1 Kafka 0.10

http://data-flair.training/blogs/apache-flink-real-world-use-case-crime-data-analysis-2/

Few Examples

https://github.com/vaquarkhan/Apache-Spark-reference-apps

Clone this wiki locally