Confluent Kafka На K8S - Застревает Офсет, Увеличивается Лаг, Что Можно Сделать?

  • Автор темы Kolya.chuprakov
  • Обновлено
  • 25, Oct 2024
  • #2

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

 

ExtraCOM


Рег
05 Jul, 2011

Тем
68

Постов
189

Баллов
539
Тем
403,760
Комментарии
400,028
Опыт
2,418,908

Интересно