ticdc 在 6.5 中对 kafka sink 做了很多性能优化的工作,这些优化不需要配打开。
关于你的报错, 是因为这些参数现阶段要写到 sink-uri 中, 如 --sink-urk “kafka://127.0.0.1:9092/test?max-message-bytes=671088&procotol=canal-json”
正在推进在配置文件中直接支持这些参数
ticdc 在 6.5 中对 kafka sink 做了很多性能优化的工作,这些优化不需要配打开。
关于你的报错, 是因为这些参数现阶段要写到 sink-uri 中, 如 --sink-urk “kafka://127.0.0.1:9092/test?max-message-bytes=671088&procotol=canal-json”
正在推进在配置文件中直接支持这些参数