Hi, I using pyflink, and I am having the following error:

py4j.protocol.Py4JJavaError: An error occurred while calling o84.executeInsert.
: org.apache.flink.table.api.ValidationException: Unable to create a source for reading table 'default_catalog.default_database.MyTopic'.

Table options are:

'connector'='kafka'
'format'='json'
'properties.bootstrap.servers'='localhost:9092'
'properties.group.id'='123212'
'topic'='MyTopic'

Does anyone know how I can solve it?

This question is better suited for #C03G7LJTS2G

ok, ty