Мы проверили, что происходит с фоновой очередью ввода-вывода и буфером. Оказалось, что с нашими производителями все в порядке, поскольку задержка увеличивалась, но, поскольку при проверке обработчиков потребителей смещение было статическим, оказалось, что мы не отправляем подтверждение Kafka при чтении, что приводит к тому, что Kafka отправляет одно и то же сообщение после таймаута при каждой попытке использования. . Что касается Java-кода, мы только что отправили подтверждение.