org.apache.flink.streaming.kafka.test

Class KafkaExample

java.lang.Object

org.apache.flink.streaming.kafka.test.base.KafkaExampleUtil

org.apache.flink.streaming.kafka.test.KafkaExample

public class KafkaExample
extends KafkaExampleUtil

A simple example that shows how to read from and write to modern Kafka. This will read String messages from the input topic, parse them into a POJO type KafkaEvent, group by some key, and finally perform a rolling addition on each key for which the results are written back to another topic.

This example also demonstrates using a watermark assigner to generate per-partition watermarks directly in the Flink Kafka consumer. For demonstration purposes, it is assumed that the String messages are of formatted as a (word,frequency,timestamp) tuple.

Example usage: --input-topic test-input --output-topic test-output --bootstrap.servers localhost:9092 --group.id myconsumer

Constructor Summary

Constructors

Constructor and Description
KafkaExample()

Method Summary

Modifier and Type	Method and Description
static void	main(String[] args)

Methods inherited from class org.apache.flink.streaming.kafka.test.base.KafkaExampleUtil

prepareExecutionEnv

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaExample

public KafkaExample()

Method Detail

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception