如何使用flink并基于scala语言，实现数据泛化解决各种数据源格式，并最终入库elasticsearch？大致的框架为通过flinkx从关系型数据库、非关系型数据库、消息队列采集数据到kafka，再由数据泛化实现数据入库
你好，我是有问必答小助手，非常抱歉，本次您提出的有问必答问题，技术专家团超时未为您做出解答
本次提问扣除的有问必答次数，将会以问答VIP体验卡（1次有问必答机会、商城购买实体图书享受95折优惠）的形式为您补发到账户。
因为有问必答VIP体验卡有效期仅有1天，您在需要使用的时候【私信】联系我，我会为您补发。