Dear all, I am experimenting with an increasing (in terms of msgs/sec) Kafka workload, where I have continuously access to the following two metrics: consumption rate per sec CRSEC and arrival rate per sec ARSEC. From the following two metrics that are continuously monitored, I want to deduce/compute the maximum consumption rate per sec MCRSEC. MCRSEC is defined as the consumption rate value that saturates the consumer, and hence the consumer can not keep up with the with the increase in the arrival rate.
Is it safe to assume the maximum consumption rate per sec MCRSEC happens when ARSEC at time t is greater than ARSEC at time t-1, while CRSEC at time t is not greater than CRSEC at time t-1? Otherwise said, ARSEC@t > ARSEC@t-1 && CRSEC@t = (not >) CRSEC@t-1? Any role for the consumer lag in the computation of MCRSEC? Thank you.
