You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by whh_960101 <wh...@163.com> on 2020/10/20 02:23:16 UTC

pyflink1.11.0 kafka connector如果有访问权限

CREATETABLEkafkaTable(user_idBIGINT,item_idBIGINT,category_idBIGINT,behaviorSTRING,tsTIMESTAMP(3))WITH('connector'='kafka','topic'='user_behavior','properties.bootstrap.servers'='localhost:9092','properties.group.id'='testGroup','format'='csv','scan.startup.mode'='earliest-offset')你好，如果使用sql语句来创建kafkaTable，kafka节点有访问权限，option里面没有设置用户名密码这一项该如何解决？