在Flink我用 kafka 元数据，深度检查时，已经加了但是仍然报错；请问还要设置什么吗？

你看一下那个gropu.id的参数，应该是表名，但是您看看new_kafka的这个参数，并不是您的源表，所以catalog有问题，这个参数是错误的。所以您检验失败。方法：创建新的kafka的catalog时，不指定group.id。CREATE CATALOG WITH(
'type'='kafka',
'properties.bootstrap.servers'='',
'format'='json',
'default-database'='',
'key.fields-prefix'='',
'value.fields-prefix'='',
'timestamp-format.standard'='',
'infer-schema.flatten-nested-columns.enable'='',
'infer-schema.primitive-as-string'='',
'infer-schema.parse-key-error.field-name'='',
'infer-schema.compacted-topic-as-upsert-table'='true',
'max.fetch.records'='100',
'aliyun.kafka.accessKeyId'='',
'aliyun.kafka.accessKeySecret'='',
'aliyun.kafka.instanceId'='',
'aliyun.kafka.endpoint'='',
'aliyun.kafka.regionId'=''
);用这个，修改一下参数，试试。参考https://help.aliyun.com/zh/flink/user-guide/manage-kafka-json-catalogs?spm=a2c4g.11186623.0.i12 此回答整理自钉群“实时计算Flink产品交流群”