连接到安装在HDInsight上的Kafka(Azure)
我需要从外部Java应用程序连接到作为Azure上HDinsight一部分启动的Kafka集群。我有3个经纪人实例,3个ZooKeeper和一个ZooKeeper客户端。连接到安装在HDInsight上的Kafka(Azure)
现在我的问题:如何指定代理连接字符串。在管理面板上,我可以看到3个经纪人:xxx-1.yyy.zzz.internal.cloudapp.net
,xxx-2.yyy.zzz.internal.cloudapp.net
- 但这些地址不可从外部获得。如果我尝试它,然后我可以看到异常:
KafkaException:无法构造卡夫卡消费者
...
ConfigException:无效的网址在bootstrap.servers: XXX-1.yyy .zzz.internal.cloudapp.net
回答:
有一个官方的文档来介绍如何HDInsight从卡夫卡通过Azure的VPN网关与外部环境连接,请参阅从here细节。
希望它有帮助。
以上是 连接到安装在HDInsight上的Kafka(Azure) 的全部内容, 来源链接: utcz.com/qa/265807.html