Я не могу найти стратегию фиксации или параметр для Kafka Connect JDB C Sink в терминах этой цели JDB C.
Это фиксирует каждые N строки или когда достигается batch.size? Что бы это ни было N строк? Размер партии или после завершения имеет смысл.
N
batch.size
Когда работник Kafka Connect выполняет задачу приемника, он будет потреблять сообщений из топических c разделов, назначенных задаче: как только разделы будут открыты для записи, Connect запустится пересылка записей из Kafka с использованием API put (Collection) .
JDB C приемник-коннектор записывает каждую партию сообщений, прошедших через метод put (Collection) , используя транзакция (размером которой можно управлять с помощью пользовательских настроек коннектора).