我已经开始为一个新项目学习一些大数据工具,现在我在卡夫卡和动物园管理员。
我让它们都安装在我的本地机器上,我可以启动它们,并开始生成和消费消息。现在,我想试一试,它有两台机器,一台是卡夫卡经纪人,一台是动物园和制片人,另一台是消费者。让我们称他们为机器A和机器B。
机器A运行的是动物园管理员服务器、代理和生产者。机器B运行一个消费者。据我所理解,我应该能够设置消费者听一个主题,从生产者从机器A,使用动物园管理员。由于这两台机器都在同一个网络上(即本地家庭网络),我想我可以更改kafka broker server.properties,以便为机器A使用我的静态ip地址,然后让机器B上的用户连接到它。
我的问题是,动物园管理员一直在本地主机上旋转,并连接到0.0.0.0/0.0.0:2181,所以当我的代理试图使用我的静态ip地址(即192.168.x.x)连接到它时,就会超时。我已经到处寻找解决方案,但是我找不到任何东西可以告诉我如何配置动物园管理员服务器来启动不同的ip地址。
也许我对这些技术的理解是错误的,但我认为这将是一件相当简单的事情。有人知道解决这个问题的方法吗?否则如果我做错了,正确的方法是什么?
发布于 2018-08-17 23:57:40
动物园管理员继续在本地主机上旋转,连接到0.0.0.0/0.0.0:2181。
那是绑定地址。
您还需要(最好)有一个静态IP给动物园管理员,然后将zookeeper.connect设置在卡夫卡的server.properties文件中,以到达另一台机器的外部地址。
在文件中,您将确保您拥有myid文件,并在属性文件中有如下所示的一行(不带双括号)
server.{{ myid }}={{ ip_address }}:2888:3888你不会在卡夫卡文档中找到这一点,但它在动物园管理员文件中
然而,如果卡夫卡和动物园管理员在同一台机器上,这是不必要的。
您的外部使用者应该设置bootstrap.servers属性和Kafka地址(Es) w/ port 9092。
你的问题可能与卡夫卡的背景。有关
例如,从listeners=PLAINTEXT://:9092开始
发布于 2020-04-02 16:36:52
对于动物园管理员3.3.0 (请参见高级配置):
clientPortAddress :3.3.0中的新地址:侦听客户端连接的地址(ipv4、ipv6或主机名);即客户端试图连接到的地址。这是可选的,默认情况下,我们绑定到服务器上任何地址/接口/网卡的clientPort连接都将被接受。
所以你可以用:
clientPortAddress=127.0.0.1https://stackoverflow.com/questions/51903498
复制相似问题