Как избежать пропущенных записей при использовании разъема KAFKA Connect JDBC Source в режиме увеличения? ⇐ MySql

[Anonymous]

Я использую источник JDBC Connect Connect JDBC для таблицы со следующими конфигурациями: < /p>

• Режим: увеличение < /li>
  Столбец увеличения: ID Первичный ключ, Auto-Increment Integer < /li>
  database: mysql (v8.0). The isolation level is REPEATABLE READ (default)

As far as I know, the connector polls the source table using id > last_max_id_seen logic, and I recently realized there’s a potential problem:

A new row (in tx A) is inserted with an id больше, чем текущий макс, который можно увидеть разъемом, и A еще не предано. last_max_id_seen, поэтому он полностью пропущен. И есть ли другие надежные шаблоны для избежания этого разрыва, не переходя к полному решению CDC, таким как Debezium?
Большое спасибо, ребята!

Подробнее здесь: https://stackoverflow.com/questions/797 ... ector-in-i