[大数据]Flink侧输出流

      在我们实际开发过程中，会出现一个flink流需要做多种处理的情况，假如我们既需要把Flink从kafka中消费的数据入到大数据数据库，又需要把主流中的部分数据拿出来发送到kafka中，这种情况就可以考虑使用flink侧输出流,通过侧输出流的数据类型不必与主要流中的数据类型相匹配，并且不同旁路输出的类型也可以不同。

下面看例子

1、maven依赖如下

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.test</groupId>
    <artifactId>flink-test</artifactId>
    <version>1.0-SNAPSHOT</version>
    <dependencies>
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-java</artifactId>
            <version>1.13.6<

创作打卡挑战赛

赢取流量/现金/CSDN周边激励大奖

了解本专栏 订阅专栏 解锁全文 超级会员免费看