August 2017
Beginner to intermediate
278 pages
6h 40m
English
The following code is a simple word count program built using a Stream API. We will go through the important APIs used in this program, and will talk about their uses:
package com.packt.Kafka;import org.apache.Kafka.common.serialization.Serde;import org.apache.Kafka.common.serialization.Serdes;import org.apache.Kafka.Streams.KafkaStreams;import org.apache.Kafka.Streams.KeyValue;import org.apache.Kafka.Streams.StreamsConfig;import org.apache.Kafka.Streams.kStream.KStream;import org.apache.Kafka.Streams.kStream.KStreamBuilder;import java.util.Arrays;import java.util.Properties;public class KafkaStreamWordCount { public static void main(String[] args) throws Exception { Properties KafkaStreamProperties = new Properties(); ...
Read now
Unlock full access