Sink Connector - Postgresql - Incorrect Handling of Default Value for Boolean Type

[kmurthyhegde]

Problem Description
Below is the schema of a boolean field (in Kafka Topic)
{
"default": true,
"field": "is_active",
"optional": false,
"type": "boolean"
}

Set the auto.create to true in the sink connector configurations.

The sink connector fails to auto create the table with the below error message:

ERROR: column "is_active" is of type boolean but default expression is of type integer

This is because the sink connector, in it's DDL, has the default value as 1 for the boolean column, instead of true.

Please let me know if there is any workaround for this issue.

[mahavir155]

@kmurthyhegde Did you found out any work around?
I too git this same issue

[jeqo]

@kmurthyhegde @mahavir155 sorry for the lack of response for a long time.

Could you confirm if this is still an issue? If it is, could you provide further detail on the postgres version? As far as I can see, boolean types support '1'/'0' as values: https://www.postgresql.org/docs/current/datatype-boolean.html as defined here:

jdbc-connector-for-apache-kafka/src/main/java/io/aiven/connect/jdbc/dialect/GenericDatabaseDialect.java

Line 1718 in 9fc5d7f

builder.append((Boolean) value ? '1' : '0');

Another workaround may be to create the table before hand before starting the connector.