KafkaAdvertised端口被更改后，Snowflake连接器失效(AWSMSK)。

在 AWS MSK 的控制台中，更改了 Kafka brokers 的 Advertised 端口，导致连接器无法正常工作。为解决此问题，需要在 AWS MSK 控制台中重新配置连接器。

下面是配置 Snowflake Connector 的示例代码：

{
    "name": "snowflake-sink",
    "config": {
        "connector.class": "com.snowflake.kafka.connector.SnowflakeSinkConnector",
        "tasks.max": "1",

        // 更改以下示例值以符合你的设置
        "topics": "kafka_topic",
        "snowflake.username": "user_name",
        "snowflake.password": "user_password",
        "snowflake.database.name": "db_name",
        "snowflake.schema.name": "schema_name",
        "snowflake.table.name.format": "table_name",
        "key.converter": "org.apache.kafka.connect.storage.StringConverter",
        "value.converter": "org.apache.kafka.connect.json.JsonConverter",
        "value.converter.schemas.enable": "false"
    }
}

在修改配置之后，通过以下命令重新启动连接器：

curl -X POST -H "Content-Type: application/json" \
-d @snowflake-sink.json http://localhost:8083/connectors

该命令将会重新加载配置并启动连接器。这样就可以解决 Snowflake Connector 在 Kafka Advertised 端口被更改后失效的问题。