Java 8，Flink 1.9.1，Azure
Event Hub
自 2020 年 1 月 5 日起，我无法再使用 flink 项目连接到 azure 事件中心。我在几个 Spring 启动应用程序上遇到了同样的问题，但是当我升级到 Spring Boot 2.2.2 时，这个问题得到了解决，它还将 Kafka 客户端和 Kafka 依赖项更新到 2.3.1。我试图更新 Flink 的 kafka 依赖项，但没有成功。我也提交了问题
https://issues.apache.org/jira/browse/FLINK-15557
2020-01-10 19：36：30,364 警告组织.apache.kafka.clients.网络客户端 - [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>;
必须使用实体级连接字符串，这就是客户端观察连接失败的原因。使用命名空间级别连接字符串时，此问题应得到解决。