Java 8，Flink 1.9.1，Azure事件中心
从2020年1月5日起，我无法再通过flink项目连接到azure事件中心。我在多个spring boot应用程序中遇到了相同的问题，但是当我升级到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警告org.apache.kafka.clients.NetworkClient-[Consumer clientId = consumer-1，groupId = ****]引导代理*****。servicebus.windows.net:9093（id：-1机架：null）已断开连接
您必须使用实体级连接字符串，这就是您的客户端观察到连接失败的原因。当使用命名空间级别的连接字符串时，该问题应该可以解决。