FLINK 基于1.15.2的Java开发-自定义Source端

开篇

之前我们讲过自定义Sink端，今天我们要讲一下自定义Source端。

自定义Source端比知定义Sink端还要简单。它只要继承自RichSourceFunction，并覆写以下几个方法就行：

@Override
    public void open(Configuration parameters) throws Exception {}
 
@Override
    public void run(SourceContext sourceContext) throws Exception {
 
@Override
    public void cancel() {
 
    }

现实需求

我们假设现在有一个这样的需求：我们自定义我们的Kafka Source，然后在接入Kafka数据源时把以下这样的数据直接转成一个ProductBean

kafka源数据：

{"productId":"a101","status":101}

ProductBean.java长这样

 * 系统项目名称 com.aldi.com.cnflink.demo ProductBean.java
 * 
 * 2022年9月27日-上午11:16:38 2022XX公司-版权所有
 * 
 */
package org.mk.demo.flink;
 
import java.io.Serializable;
 
/**
 * 
 * ProductBean
 * 
 * 
 * 2022年9月27日 上午11:16:38
 * 
 * @version 1.0.0
 * 
 */
public class ProductBean