Closed karaikyo closed 1 month ago
kafka版本：3.5.1 ES版本：7.17.24 KnowStreaming源码版本：3.4
kafka，ES在同一服务器，然后本地源码启动过程中会连接zookeeper获取一些健康信息，但是看日志里连接zookeeper使用的ip地址是localhost，从而导致连接失败。kafka的server.properties中的zookeeper.connect配置的是实际ip。想知道这个localhost是如何获取到的，要如何改成实际的ip地址。
zookeeper.connect
在AbstractHealthCheck类中的calAndUpdateHealthCheckResult(ClusterPhy clusterPhy, long triggerTimeUnitMs)方法中，clusterPhy中zookeeper的值是localhost:2181。此外这个方法中调用了HealthCheckZookeeperService类的getResList(Long clusterPhyId)方法获取一些配置信息，getResList()的第一行代码ClusterPhy clusterPhy = LoadedClusterPhyCache.getByPhyId(clusterPhyId);的LoadedClusterPhyCache这个类中的PHY_CLUSTER_MAP里的zookeeper也同样是localhost:2181
AbstractHealthCheck
calAndUpdateHealthCheckResult(ClusterPhy clusterPhy, long triggerTimeUnitMs)
clusterPhy
localhost:2181
HealthCheckZookeeperService
getResList(Long clusterPhyId)
getResList()
ClusterPhy clusterPhy = LoadedClusterPhyCache.getByPhyId(clusterPhyId);
LoadedClusterPhyCache
PHY_CLUSTER_MAP
在这里提出你的问题
kafka版本：3.5.1 ES版本：7.17.24 KnowStreaming源码版本：3.4
kafka，ES在同一服务器，然后本地源码启动过程中会连接zookeeper获取一些健康信息，但是看日志里连接zookeeper使用的ip地址是localhost，从而导致连接失败。kafka的server.properties中的
zookeeper.connect配置的是实际ip。想知道这个localhost是如何获取到的，要如何改成实际的ip地址。在
AbstractHealthCheck类中的calAndUpdateHealthCheckResult(ClusterPhy clusterPhy, long triggerTimeUnitMs)方法中，clusterPhy中zookeeper的值是localhost:2181。此外这个方法中调用了HealthCheckZookeeperService类的getResList(Long clusterPhyId)方法获取一些配置信息，getResList()的第一行代码ClusterPhy clusterPhy = LoadedClusterPhyCache.getByPhyId(clusterPhyId);的LoadedClusterPhyCache这个类中的PHY_CLUSTER_MAP里的zookeeper也同样是localhost:2181