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

時間 2020-01-13

標籤 kafka lag 延遲引起 partitions consumers 調整欄目 Kafka 简体版

原文原文鏈接

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

>>阅读原文<<