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