版本的问题跟他们确认过：v2.4.1 ，我创建的语句如下 –sink-uri="kafka://xxxxxx:9092/tidb_xxxx?protocol=canal-json&kafka-version=2.4.1&
