For example, if a flink job reads from kafka do something and writes to kafka. Do we need to take any actions when the job kafka consumer lag is low or 0 but some tasks have constant backpressure? Do we need to increase the parallelism or do some network tuning so that backpressure is constant 0? If so, would that lead to resource overprovision?
Or is it that only when kafka lag keeps increasing while backpressure is happening at the same time, we need to take action? Best Lu
