Questa è una domanda molto complessa:prima di tutto, le impostazioni di memoria predefinite per le immagini di Debezium Docker sono piuttosto basse, quindi se le stai utilizzando potrebbe essere necessario aumentarle.
Successivamente, ci sono più fattori in gioco. Ti consiglio di eseguire i seguenti passaggi.
- Aumenta
max.batch.size
emax.queue.size
- riduce il numero di commit - Aumenta
offset.flush.timeout.ms
- concede a Connect il tempo di elaborare i record accumulati - Diminuisci
offset.flush.interval.ms
- dovrebbe ridurre l'importo delle compensazioni accumulate
Sfortunatamente esiste un numero KAFKA-6551 in agguato nel backstage che può ancora creare scompiglio.