Исключение Kafka Connect CDC для MS SQL sourceOffset

Question

Мы используем коннектор Confluent MS SQL CDC, а дескриптор соединения:

curl -X POST -H \
  "Content-Type: application/json" --data '{
    "name" : "yury-mssql-cdc1",
    "config" : {
      "connector.class" : "io.confluent.connect.cdc.mssql.MsSqlSourceConnector",
      "tasks.max" : "1",
      "initial.database" : "test2",
      "username" : "user",
      "password" : "pass",
      "server.name" : "some-server.eu-west-1.rds.amazonaws.com",
      "server.port" : "1433",
      "change.tracking.tables" : "dbo.foobar"
    }
  }' \
   http://ip-10-0-0-24.eu-west-1.compute.internal:8083/connectors

вся инфраструктура развернута на AWS ... и исключение:

Сгенерировано исключение ошибкипри запросе ChangeKey

{databaseName = test2, schemaName = dbo, tableName = foobar} (io.confluent.connect.cdc.mssql.QueryService: 94) java.lang.NullPointerException: источник не может бытьnull.

любая помощь будет принята с благодарностью.

Answer 1

Я нашел ответ, мне кажется, проблема в том, как сконфигурирован SQL Server CDC.Мы не должны использовать старый способ установки CDC (EXEC sys.sp_cdc_enable_db и EXEC sys.sp_cdc_enable_table)

Вместо этого используйте следующую команду для настройки SQL-сервера CDC

ALTER DATABASE [имя базы данных]SET CHANGE_TRACKING = ON (CHANGE_RETENTION = 2 дня, AUTO_CLEANUP = ON) GO ALTER DATABASE [имя базы данных] SET ALLOW_SNAPSHOT_ISOLATION ON GO ALTER TABLE [имя тальба] ENABLE CHANGE_TRACKING с (TRACK_COLUMNS) *