flink 1.9.1无法再连接到azure事件中心

dsekswqp  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(344)

java 8,
Flink1.9.1,
azure事件中心
从2020年1月5日起,我无法再使用flink项目连接到azure event hub。我在几个spring-boot应用程序中也遇到了同样的问题,但当我升级到spring-boot2.2.2时,问题得到了解决,它还将kafka客户端和kafka依赖项更新到了2.3.1。我试图更新Flink的Kafka依赖关系,但没有成功。我还提交了一个问题
https://issues.apache.org/jira/browse/flink-15557
2020-01-10 19:36:30364警告org.apache.kafka.clients.networkclient-[consumer clientid=consumer-1,groupid=***]引导代理***.servicebus.windows。net:9093 (id:-1机架:空)已断开
连接属性

"sasl.mechanism"="PLAIN");
"security.protocol"="SASL_SSL");
"sasl.jaas.config"="Endpoint=sb://<FQDN>/;SharedAccessKeyName=<KeyName>;SharedAccessKey=<KeyValue>;EntityPath=<EntityValue>;
ojsjcaue

ojsjcaue1#

您必须使用实体级别的连接字符串,这就是您的客户机观察到连接失败的原因。当使用命名空间级别的连接字符串时,应该解决此问题。

相关问题