由kafka的lag延遲引起的partitions數和consumers數的調整

問題描述： 有一個topic爲nams_flume_imp，有兩個消費者組**-imp-adv-log 和 ****_logstash_imp來消費該topic，每一個消費者組目前只有一個消費者，每一個消費者只有一個線程。 Kafka有6個partition，也就是說每一個消費者組只有一個消費者線程來消費6個partition的log數據。 經過查看kafkamanage，發現****_logst

>>阅读原文<<