Flink(2)——定制输入输出源

概要

本文先从上一篇中的本地输入输出出发，先制作从 Kafka 输入，再制作输出到 MySQL

本地输入输出

代码

kafka 输入, stdout 输出
代码
输出类 StdoutSink.java

kafka 输入测试
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic fw-blink-test

结果查看
$ tailf flink-abeffect-jobmanager-0-fox.local.out
3
1
2
3
11
12
13

kafka 输入, mysql 输出
代码
输出类 MySQLSink.java

kafka 输入测试
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic fw-blink-test

结果查看
mysql> select * from sink0;
+----+------+
| id | key  |
+----+------+
|  1 | 000  |
|  2 | a2   |
|  3 | a3   |
|  4 | b1   |
|  5 | b2   |
|  6 | b3   |
+----+------+