可是我设置了key.converter.schemas.enable=false,value.converter.schemas.enable=false后还是有模式信息
时间: 2024-04-11 12:30:17 浏览: 267
CoolUtils Total Audio Converter V5.2.130+key
如果在设置`key.converter.schemas.enable=false`和`value.converter.schemas.enable=false`后仍然存在模式信息,这可能是因为您使用的是Debezium连接器的默认转换器,该转换器可能会默认包含模式信息。
要解决这个问题,您可以尝试使用自定义的转换器,例如使用`org.apache.kafka.connect.json.JsonConverter`作为键和值的转换器,并将模式信息禁用。您可以按照以下步骤进行设置:
1. 在Kafka Connect的配置文件中,配置Debezium连接器使用自定义的键和值转换器。设置以下参数:
- `key.converter=org.apache.kafka.connect.json.JsonConverter`
- `value.converter=org.apache.kafka.connect.json.JsonConverter`
2. 确保您已将以下属性设置为`false`:
- `key.converter.schemas.enable=false`
- `value.converter.schemas.enable=false`
3. 启动Kafka Connect并验证是否成功监听并将变更数据传递到Kafka主题。消费者可以从该主题订阅数据。
通过这些步骤,您应该能够使用自定义的JsonConverter转换器,并且禁用了模式信息。
如果仍然存在模式信息,您还可以尝试其他的Kafka Connect转换器,或者查阅Debezium文档以了解如何禁用模式信息的包含。
请注意,具体的设置和配置可能因您使用的工具和版本而有所不同。您需要根据您的实际情况进行适当的调整和配置。
希望这次回答对您有所帮助!如果您还有其他问题,请随时提问。
阅读全文