Building Data Streaming Applications with Apache Kafka

Java example for direct approach

Again, let us take a Java example:

import java.util.HashMap;import java.util.HashSet;import java.util.Arrays;import java.util.Map;import java.util.Set;import java.util.regex.Pattern;import scala.Tuple2;import kafka.serializer.StringDecoder;import org.apache.Spark.SparkConf;import org.apache.Spark.streaming.api.java.*;import org.apache.Spark.streaming.kafka.KafkaUtils;import org.apache.Spark.streaming.Durations;public class JavaDirectKafkaWordCount {    private static final Pattern SPACE = Pattern.compile(" ");    public static void main(String[] args) throws Exception {        String brokers = "localhost:9092";        String topics = "test";        SparkConf SparkConf = new SparkConf().setAppName("DirectKafkaWordCount"); JavaStreamingContext ...