logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

Flink1.14新版kafkaSource和kafkaSink

工具类public class KafkaUtils {/*** 功能描述: <br>* 〈自定义build,生产kafkaSource〉* @Param: [env, topic, groupId, offsets]* @Return: org.apache.flink.streaming.api.datastream.DataStreamSource<java.lang.St

#kafka#java#flink +1
暂无文章信息