我想经营多个Kafka经纪公司的mesos马拉松工作。我正在考虑使用什么作为代理id。我知道有些人正在使用基于ip的代理id,但我了解到,这种方法在将代理迁移到不同的机器时不是最佳的。有什么见解吗?与此相关的是,有没有一种方法可以滚动部署kafka代理,即marathon等待旧代理示例将数据复制到新代理示例,然后再杀死它们。
hof1towb1#
我创建了一个docker图像,可以从马拉松开始,也可以放大和缩小。为了获得唯一的代理id,我将ip地址的最后八位字节和marathon设计的端口号连接到docker容器。我知道这应该不是问题,因为通常客户端通过zookeeper连接,zookeeper本身就有节点和它们的连接信息,所以不需要关注细节。或者我误解了这个问题。。。看一看http://kafka.apache.org/documentation.html#replication
1条答案
按热度按时间hof1towb1#
我创建了一个docker图像,可以从马拉松开始,也可以放大和缩小。为了获得唯一的代理id,我将ip地址的最后八位字节和marathon设计的端口号连接到docker容器。
我知道这应该不是问题,因为通常客户端通过zookeeper连接,zookeeper本身就有节点和它们的连接信息,所以不需要关注细节。或者我误解了这个问题。。。
看一看
http://kafka.apache.org/documentation.html#replication