C'est une question très complexe - tout d'abord, les paramètres de mémoire par défaut pour les images Debezium Docker sont assez bas, donc si vous les utilisez, il peut être nécessaire de les augmenter.
Ensuite, plusieurs facteurs entrent en jeu. Je recommande de suivre les étapes suivantes.
- Augmenter
max.batch.sizeetmax.queue.size- réduit le nombre de commits - Augmenter
offset.flush.timeout.ms- donne à Connect le temps de traiter les enregistrements accumulés - Réduire
offset.flush.interval.ms- devrait réduire le montant des compensations accumulées
Malheureusement, il existe un problème KAFKA-6551 caché dans les coulisses qui peut encore faire des ravages.
