The first step is to modify our Kioto project. We have to add the dependencies to build.gradle, as shown in Listing 8.1:
apply plugin: 'java'
apply plugin: 'application'
sourceCompatibility = '1.8'
mainClassName = 'kioto.ProcessingEngine'
repositories {
mavenCentral()
maven { url 'https://packages.confluent.io/maven/' }
}
version = '0.1.0'
dependencies {
compile 'com.github.javafaker:javafaker:0.15'
compile 'com.fasterxml.jackson.core:jackson-core:2.9.7'
compile 'io.confluent:kafka-avro-serializer:5.0.0'
compile 'org.apache.kafka:kafka_2.12:2.0.0'
compile 'org.apache.kafka:kafka-streams:2.0.0'
compile 'io.confluent:kafka-streams-avro-serde:5.0.0'
compile 'org.apache.spark:spark-sql_2.11:2.2.2'
compile 'org.apache...