Debezium SQL Серверный коннектор Kafka Initial Snapshot

Question

согласно документации Debezium SQL Server Connector, первоначальный снимок срабатывает только при первом запуске коннектора. Однако, если я удалю соединитель и создаю новый, но с тем же именем , начальный снимок также не будет работать. Это намеренно или известная проблема? Любая помощь приветствуется

Answer 1

Присвойте коннектору новое значение database.server.name или создайте новый topi c. Причина, по которой моментальный снимок не срабатывает снова, заключается в том, что текущее значение смещения для вашего topi c и потребителя уже прошло индекс подсчета снимков.

Answer 2

Kafka Connect хранит сведения о соединителях, такие как состояние их снимков и прогресс загрузки, даже после того, как они были удалены. Если вы воссоздадите его с тем же именем, он будет считать, что это тот же разъем, и, таким образом, попытается продолжить с того места, где был предыдущий.

Если вы хотите, чтобы коннектор запускался с нуля (т. Е. Запускал моментальный снимок и c), то вам нужно дать коннектору новое имя . (Технически вы также можете go в Kafka Connect и возиться с внутренними данными, чтобы удалить данные для одноименного соединителя, но это, вероятно, плохая идея)