Det här är en mycket komplex fråga - för det första är standardminnesinställningarna för Debezium Docker-bilder ganska låga så om du använder dem kan det vara nödvändigt att öka dem.
Därefter är det flera faktorer som spelar in. Jag rekommenderar att du gör följande steg.
- Öka
max.batch.sizeochmax.queue.size- minskar antalet åtaganden - Öka
offset.flush.timeout.ms- ger Connect tid att bearbeta ackumulerade poster - Minska
offset.flush.interval.ms- bör minska mängden ackumulerade offset
Tyvärr finns det ett problem KAFKA-6551 lurar i kulisserna som fortfarande kan göra förödelse.