kafka消费速度慢可以尝试以下方法进行调优 1.根据topic分区数来调整消费者实例数 众所周知,kafka为了保证消息消费顺序topic的每个分区只能被消费者组中一个实例消费。 如果你的topic分区数为36,则可以尝试调整消费者实例数为36,当然这个是消费者ConsumerFactory.concurrency=1的情况。如果你调整了线程数为n,则你的消费者实例数最优为Math.ceil(36/n)。 2.开启消费者批量消费 可以把ConcurrentKafkaListenerContainerFactory.setBatchListener(true)开启批量消费,并配置批量消费数...

  ewyNyIHXRIzp   2023年11月01日   60   0   0 Java
关注 更多

空空如也 ~ ~

粉丝 更多

空空如也 ~ ~