如何配置Debezium Mysql连接器生成原始键而不是struct或json对象？

在配置Debezium Mysql连接器生成原始键而不是struct或json对象时，您可以按照以下步骤进行操作：

1. 在配置文件中设置"key.converter"参数为"org.apache.kafka.connect.storage.StringConverter"，指定键的转换器为String类型。
2. 设置"key.converter.schemas.enable"参数为"false"，禁用键的schema。
3. 将"key.converter.schemas.enable"参数设置为"false"时，需同时设置"key.converter"参数为"org.apache.kafka.connect.json.JsonConverter"或"org.apache.kafka.connect.json.JsonConverterConfig"。
4. 针对Debezium Mysql连接器，您还可以配置"transforms"参数，使用内置的"unwrap"转换器，将记录的值解包为原始格式。

具体的配置如下：

{
  "name": "mysql-connector",
  "config": {
    "connector.class": "io.debezium.connector.mysql.MySqlConnector",
    "key.converter": "org.apache.kafka.connect.storage.StringConverter",
    "key.converter.schemas.enable": "false",
    "key.converter.schema.registry.url": "your-schema-registry-url",
    "transforms": "unwrap",
    "transforms.unwrap.type": "io.debezium.transforms.UnwrapFromEnvelope",
    "database.hostname": "your-database-hostname",
    "database.port": "your-database-port",
    "database.user": "your-database-username",
    "database.password": "your-database-password",
    "database.server.id": "your-server-id",
    "database.server.name": "your-database-server-name",
    "database.whitelist": "your-database-whitelist",
    "database.history.kafka.bootstrap.servers": "your-bootstrap-servers",
    "database.history.kafka.topic": "your-history-topic"
  }
}

配置说明：

• "name"：连接器的名称，可自定义。
• "connector.class"：连接器的类名，指定为Debezium Mysql连接器。
• "key.converter"：指定键的转换器为StringConverter。
• "key.converter.schemas.enable"：禁用键的schema。
• "key.converter.schema.registry.url"：指定schema registry的URL，如果使用了schema registry。
• "transforms"：指定转换器的列表，使用"unwrap"转换器进行解包。
• "transforms.unwrap.type"：指定解包转换器的类名。
• "database.hostname"：数据库主机名。
• "database.port"：数据库端口号。
• "database.user"：数据库用户名。
• "database.password"：数据库密码。
• "database.server.id"：数据库服务器的唯一ID。
• "database.server.name"：数据库服务器的名称。
• "database.whitelist"：需要监控的数据库白名单。
• "database.history.kafka.bootstrap.servers"：Kafka的引导服务器列表。
• "database.history.kafka.topic"：用于记录数据库历史的Kafka主题。

这样配置后，Debezium Mysql连接器将生成原始键而不是struct或json对象。

腾讯云相关产品和产品介绍链接：

• 腾讯云云数据库 MySQL：https://cloud.tencent.com/product/cdb
• 腾讯云云服务器 CVM：https://cloud.tencent.com/product/cvm
• 腾讯云云原生容器服务 TKE：https://cloud.tencent.com/product/tke
• 腾讯云消息队列 CKafka：https://cloud.tencent.com/product/ckafka