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