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

問題描述: 有一個topic爲nams_flume_imp,有兩個消費者組**-imp-adv-log 和 ****_logstash_imp來消費該topic,每一個消費者組目前只有一個消費者,每一個消費者只有一個線程。 Kafka有6個partition,也就是說每一個消費者組只有一個消費者線程來消費6個partition的log數據。 經過查看kafkamanage,發現****_logst
相關文章
相關標籤/搜索