Skip to main content

Kafka Connect JDBC Sink - SQLServerException: Column in table is of a type that is invalid for use as a key column in an index

I encounter the same issue as https://github.com/confluentinc/kafka-connect-jdbc/issues/379

I think I could contribute to implement a custom `buildCreateTableStatement` in SqlServerDatabaseDialect that checks if primary key is a string, set it as VARCHAR(450) and logs it as warning.

any suggestion?

Comments