Flink 1.9.1无法再连接到Azure事件中心

Question

Java 8，

Flink 1.9.1，

Azure事件中心

我不能再连接到蔚蓝事件中心与我的flink项目，从2020年1月5日。我在几个spring引导应用程序中也有同样的问题，但是当我升级到SpringBoot2.2.2时，这个问题得到了解决，SpringBoot2.2.2也将Kafka客户端和Kafka依赖项更新为2.3.1。我试图更新Flink的kafka依赖，但没有成功。我还提交了一个问题

https://issues.apache.org/jira/browse/FLINK-15557

2020-01-10 19:36:30,364 org.apache.kafka.clients.NetworkClient -消费客户端=消费者-1，groupId=**** Bootstrap broker *****.servicebus.windows.net:9093 (id：-1齿条: null)断开连接

连接特性

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

Answer 1

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