Как узнать, есть ли у Debezium какие-либо не связанные с потоком изменения для потоковой передачи в Kafka?

Question

Я хочу использовать Debezium для потоковой передачи изменений (на CD C) из группы таблиц в некоторых базах данных сервера MS SQL в Kafka. Эти таблицы будут иметь развивающуюся структуру.

Чтобы изменить захваченные столбцы, я должен:

1. Прекратить публикацию новых данных
2. Дождаться потоковой передачи Debezium любые изменения в Kafka
3. Disable CD C
4. Внесите изменения в схемы
5. Enable CD C
6. ...

Однако как мне узнать, что Debezium завершил потоковую передачу всех изменений в Kafka? Я не могу найти никакой документации о каком-либо API / конечной точке в Debezium, которая сообщает мне ее статус. Кроме того, есть ли какой-либо API / конечная точка, которую я могу нажать между (1) и (2), чтобы специально проинструктировать Debezium о гриппе sh CD C немедленно переходит на Kafka?

Спасибо

Answer 1

Я думаю, что самый безопасный подход - это сравнение LSN базы данных с LSN, который хранится в смещениях соединителя. Таким образом, вы будете уверены, какие изменения коннектор обнаружил и зафиксировал в Kafka.