Flink Sink定制开发

一、KafkaSink 1、按流内容分发到对应topic，隔天自动切换 在flink自带的kafka sink实现里，只支持写到固定topic，而a56爆大奖在线娱乐们的kafka2kafka日志处理逻辑要求消息要按照ds字段值写入到对应topic，topic名前缀相同，后面跟ds字段值，需要进行改造 具体实现思路如
posted @ 2020-04-22 19:25  码以致用  阅读(1487)  评论(0)  编辑  收藏  举报