Ini adalah pertanyaan yang sangat kompleks - pertama-tama, pengaturan memori default untuk gambar Debezium Docker cukup rendah sehingga jika Anda menggunakannya, mungkin perlu untuk meningkatkannya.
Selanjutnya, ada banyak faktor yang berperan. Saya sarankan untuk melakukan langkah-langkah berikut.
- Meningkatkan
max.batch.sizedanmax.queue.size- mengurangi jumlah komit - Meningkatkan
offset.flush.timeout.ms- memberi Connect waktu untuk memproses akumulasi catatan - Kurangi
offset.flush.interval.ms- harus mengurangi jumlah akumulasi offset
Sayangnya ada masalah KAFKA-6551 bersembunyi di belakang panggung yang masih bisa membuat kekacauan.