Как бороться с растущим consumer lag в Kafka?