Open hongbo-miao opened 5 months ago
Thank you for your remark. We will look into that!
I did check the code base - there is case insensitive comparison of the configuration values, so any lower/upper case letter combination of allowed values works fine in our test scenarios. Is there a chance you are using some specific locale settings in your environment? The only case where this could potentially fail is user provided value conversion to lowercase.
Hi @sfc-gh-gjachimko I passed in through Terraform at https://github.com/Hongbo-Miao/hongbomiao.com/blob/06a7796cf01a9cd56d177a3edb23e0986bd7857e/cloud-infrastructure/terraform/modules/aws/hm_amazon_msk_connector/main.tf#L56-L56
@hongbo-miao i've double checked this at our side - it seems to be case insensitive - https://github.com/snowflakedb/snowflake-kafka-connector/blob/2b66a638924076858a6b1112c94027a56f590c18/src/test/java/com/snowflake/kafka/connector/ConnectorConfigTest.java can you confirm it is still an issue for you?
@hongbo-miao i've double checked this at our side - it seems to be case insensitive - https://github.com/snowflakedb/snowflake-kafka-connector/blob/2b66a638924076858a6b1112c94027a56f590c18/src/test/java/com/snowflake/kafka/connector/ConnectorConfigTest.java can you confirm it is still an issue for you?
Thanks @sfc-gh-gjachimko ! The link you posted does not point to specific line. If you could locate specific line throw this error in my fist post, specific this one
org.apache.kafka.common.config.ConfigException: Invalid value ALL for configuration errors.tolerance: String must be one of: none, all
ERROR Uncaught exception in REST call to /connectors/DevelopmentMySinkConnector/restart
it may help.
Terraform is case-sensitive.
I saw there is a new v2.2.2 connector published, I will give it a try and report back soon, thanks!
Hi @sfc-gh-gjachimko
This time, I tested on latest MSK 3.7.x with latest snowflake-kafka-connector v2.2.2.
I can confirm the issue still exists on snowflake-kafka-connector v2.2.2, all
works while ALL
does not work.
Here is
thank you for details!
(Just found a small doc issue, if this place is not proper place to post, it would be great to let me know where, thanks!)
I am using MSK 3.6.0 and snowflake-kafka-connector 2.2.1
When I use
"errors.tolerance": "ALL"
in the connector, I got error:After updating to lowercase
"errors.tolerance": "all"
, the issue is gone for me.It would be great to update the document to lowercase, thanks! ☺️