September 2017
Beginner to intermediate
360 pages
8h 13m
English
We have discussed Apache Kafka setup in previous chapters, so we will focus on Java code to integrate Flink and Kafka.
Follow the given steps:
<dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-streaming-java_2.11</artifactId> <version>1.2.0</version></dependency>
The previous dependency is required for all type of the integration. The following dependencies are specific to Flink and Kafka integration:
<dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-connector-kafka-0.8_2.11</artifactId> <version>1.2.0</version></dependency><dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.11</artifactId> <version>0.8.2.2</version></dependency> ...
Read now
Unlock full access