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里面没有设置用户名密码这一项该如何解决?
- pyflink sql中select,where都带udf,其中一个udf失效 whh_960101
- pyflink sql中select,where都带udf,其中一个udf失效 whh_960101
- Re: pyflink sql中select,where都带udf,其中一个udf失效 Xingbo Huang
- Re:Re: pyflink sql中select,where都带udf,其中一个udf失效 whh_960101
- Re:Re: pyflink sql中select,where都带udf,其中一个udf失效 whh_960101
- Re:Re: pyflink sql中select,where都带udf,其中一个udf失效 whh_960101
- Re: pyflink sql中select,where都带udf,其中一个udf失效 Dian Fu
- Re:Re: pyflink sql中select,where都带udf,其中一个udf失效 whh_960101
- Re:Re: pyflink sql中select,where都带udf,其中一个udf失效 whh_960101
- Re: pyflink sql中select,where都带udf,其中一个udf失效 Dian Fu
- pyflink1.11.0 kafka connector如果有访问权限 whh_960101
- pyflink1.11.0 报错JobExecutionException: Job execution failed. whh_960101
- Re: pyflink1.11.0 报错JobExecutionException: Job execution fail... Dian Fu
- Re: pyflink1.11.0 报错JobExecutionException: Job execution fail... Dian Fu
- Re:Re: pyflink1.11.0 报错JobExecutionException: Job execution f... whh_960101
- Re: pyflink1.11.0 报错JobExecutionException: Job execution fail... Dian Fu
- pyflink1.11.0 如果elasticsearch host有访问权限,connector如何写入用户名密码 whh_960101
- Re: pyflink1.11.0 如果elasticsearch host有访问权限,connector如何写入用户名密... Yangze Guo
- Re:Re: pyflink1.11.0 如果elasticsearch host有访问权限,connector如何写入用... whh_960101
- Re:Re: pyflink1.11.0 如果elasticsearch host有访问权限,connector如何写入用... whh_960101
- Re:Re: pyflink1.11.0 如果elasticsearch host有访问权限,connector如何写入用... whh_960101