大家好,求助一下。
     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. 

回复