凡客建站快车,网业认证wifi入口,上海高端网站建设公,商业网站建设与运营实时数仓中#xff0c;为什么没有零点漂移问题#xff1f; 因为flink直接取的事件时间用kafka是为了速度快#xff0c;并且数据不丢#xff0c;那为什么既用了kafkachannel#xff0c;也用了kafka#xff0c;而不只用kafkachannel呢#xff1f; 因为需要削峰填谷离线数仓…实时数仓中为什么没有零点漂移问题 因为flink直接取的事件时间用kafka是为了速度快并且数据不丢那为什么既用了kafkachannel也用了kafka而不只用kafkachannel呢 因为需要削峰填谷离线数仓中为什么用两个flume一个kafka直接用taildirsource,kafkachannel,hdfssink不行吗 不行kafka可以削峰填谷如果用kafkachannel那么数据写到kafka只剩event没有header无法解决零点漂移问题而多加一个flume可以在kafkasource中添加拦截器。
