Това е много сложен въпрос - първо, настройките на паметта по подразбиране за изображенията на Debezium Docker са доста ниски, така че ако ги използвате, може да се наложи да ги увеличите.
След това има много фактори в играта. Препоръчвам да направите следните стъпки.
- Увеличете
max.batch.size
иmax.queue.size
- намалява броя на ангажиментите - Увеличете
offset.flush.timeout.ms
- дава време на Connect за обработка на натрупаните записи - Намалете
offset.flush.interval.ms
- трябва да намали размера на натрупаните компенсации
За съжаление има проблем KAFKA-6551 дебнещи се зад кулисите, които все още могат да направят хаос.