张大伟
这家伙太懒，什么都没留下
这家伙太懒，什么都没留下
flink我没用过，我简单的帮你分析一下。
首先，kafka消费者是批量获取消息的，所以一般瓶颈不会在数据拿的慢，而是在消费处理的慢。也就是说flink拿到消息，但是消化的慢，导致整体慢。
你可以增加消费者数量，也就是flink来分化消息（最多不能超过10个，依据你的分区大小），看看是否效率有所提升。
