Как увеличить производительность, если в Kafka копится consumer lag?