kafka 启动消费者报错:Error while fetching metadata with correlation id 2
flink1.12.x sink-发送数据到kafka(自定义序列化器)
flink1.12.x Connector连接器
flink1.12.x sink-JdbcSink保存数据到mysql数据库
flink1.12.x sink-FileSink写入到文件(HDFS)
flink1.12.x 重分区算子-global()
flink1.12.x 重分区算子-forward()
flink1.12.x Operator chain(未完)
flink1.12.x 打印执行计划
flink1.12.x 设置并行度(并发)、最大并发度