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.size
danmax.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.