由kafka的lag延迟引起的partitions数和consumers数的调整

问题描述: 有一个topic为nams_flume_imp,有两个消费者组**-imp-adv-log 和 ****_logstash_imp来消费该topic,每一个消费者组目前只有一个消费者,每一个消费者只有一个线程。 Kafka有6个partition,也就是说每一个消费者组只有一个消费者线程来消费6个partition的log数据。 经过查看kafkamanage,发现****_logst
相关文章
相关标签/搜索