Esta es una pregunta muy compleja:en primer lugar, la configuración de memoria predeterminada para las imágenes de Debezium Docker es bastante baja, por lo que si las está utilizando, es posible que deba aumentarlas.
A continuación, hay múltiples factores en juego. Recomiendo seguir los siguientes pasos.
- Aumentar
max.batch.sizeymax.queue.size- reduce el número de confirmaciones - Aumentar
offset.flush.timeout.ms- le da a Connect tiempo para procesar los registros acumulados - Reducir
offset.flush.interval.ms- debería reducir la cantidad de compensaciones acumuladas
Desafortunadamente, hay un problema KAFKA-6551 acechando en el backstage que todavía puede causar estragos.
