通过azure webapp(java)连接到kafka hdinsight群集

gg0vcinb  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(416)

我正在探索azure相关技术。
我已经用java创建了azurewebapp。
在azure上创建了kafka hdinsight群集。
如何通过azure java webapp(请参见第1点)连接到kafka群集(请参见第2点)?
我做的一件事是从ambari用户界面获取主机名,在我的webapp中配置kafka,但它似乎不起作用。
另外,如何在kafka hdinsight集群中查看日志/数据?
连接的webapp代码:“10.0.0.13:9092”地址取自ambari ui

Properties properties = new Properties();
    String servers = "10.0.0.13:9092";
    properties.put("bootstrap.servers", servers);
    properties.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
    properties.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

    kafkaProducer = new KafkaProducer(properties);
fykwrbwg

fykwrbwg1#

hdinsight不允许通过公共互联网直接连接到kafka>hdinsight架构规划。如果您想使用java web app(在tomcat中),可能的解决方案之一是为web app配置vnet集成(vpn),并重新配置kafka以播发代理的ip而不是名称,因为dns名称解析将无法通过vpn>为ip播发配置kafka来工作。
p、 对于应用服务linux计划(容器),目前不支持vnet集成

相关问题