当只有一个代理可以从生产者访问，没有一个zookeeper节点可以从生产者访问，但是所有代理都是健康的并且可以从彼此访问时，是否可以生成Kafka主题？
例如，如果我要通过ssh隧道生成消息，那么这是必需的。如果这是一个临时推送，我可能会用复制因子1创建主题，并将所有分区分配给有问题的代理，然后在事后重新分配分区，但我希望有一个更灵活的设置。
这都是使用java客户机。
当只有一个代理可以从生产者访问，没有一个zookeeper节点可以从生产者访问，但是所有代理都是健康的并且可以从彼此访问时，是否可以生成Kafka主题？
例如，如果我要通过ssh隧道生成消息，那么这是必需的。如果这是一个临时推送，我可能会用复制因子1创建主题，并将所有分区分配给有问题的代理，然后在事后重新分配分区，但我希望有一个更灵活的设置。
这都是使用java客户机。
1条答案
按热度按时间ryoqjall1#
制作人不与Zookeeper互动，所以这不是问题。
生产者的唯一要求是能够连接到代理，代理是他们想要使用的分区的领导者。
如果您连接到的代理是您要使用的分区的前导，那么您可以向它生成yes。
否则就不行了。另外，创建一个主题可能没有帮助，因为它的分区可能被分配给任何代理。此外，为了创建主题，客户机必须连接到控制器，而控制器可能不是您可以访问的代理。
如果您只能连接到一个“thing”，您可能需要考虑使用rest代理之类的东西。您的“隔离”环境可以向代理发送rest请求，该代理能够连接到集群中的所有代理。