2017-12-27 313 views
0

我需要从外部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

回答

0

有一个官方的文档来介绍如何HDInsight从卡夫卡通过Azure的VPN网关与外部环境连接,请参阅从here细节。

希望它有帮助。