Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:172)
org.apache.kafka.connect.errors.DataException: JsonConverter with schemas.enable requires "schema" and "payload" fields and may not contain additional fields. If you are trying to deserialize plain JSON data, set schemas.enable=false in your converter configuration.
这个该如何解决
JsonConverter转换异常,仔细读下这个错误。
知道是这个异常,但是为什么会出现这个异常呢,按照https://www.orchome.com/6这个步骤做的
你把执行的命令发下看看。
你的答案