我在VNET中创建了一个多节点Azure Databricks集群&我在不同的VNET中创建了一个多节点Kafka HDInsight集群。我已经看过这两个VNET了。在对等之后,我的两台机器能够相互ping通。
我正在尝试使用Spark Structured将消息从Databricks集群转储到Kafka主题&我收到套接字超时错误。
经过研究,我发现在Kafka中,我们需要在server.properties文件中设置listeners & advertised.listeners。
在我的场景中,应该为listeners和advertised.listeners设置什么值?这将是非常有帮助的,如果任何人可以建议我在server.properties文件中我需要做的所有更改。
发布于 2019-07-17 21:35:56
您需要为主机/IP创建一个侦听器,在该主机/IP上,您的客户端计算机(运行Spark )可以连接到您的代理。
https://stackoverflow.com/questions/57077027
复制相似问题