大家好,求助一下。
FIink SQL> create table kafka_source(
> messageKey varbinary,
> message varbinary,
> topic varchar,
>'partition' int,
> 'offset' bigint
>) with (
> type='kafka011',
> topic='test',
> bootstrap. servers='thcathost:9092',
> 'group. id'='chf'
>); [ERROR] Unknown or invalid SQL statement.
