2017-04-11 32 views

回答

0

我认为你的意思是要问如何维护Kafka经纪人之间的副本,这些经纪人一起被认为是Kafka集群。

如果是这样的话,这是很简单的,你所要做的就是配置一个卡夫卡集群,并创造与大小复制因子等于在群集节点的大小的话题。

例如:

比方说,我们要对我们的卡夫卡集群3个经纪商,那么你就需要为每个经纪人准备不同的配置文件,然后启动它们作为一个集群,并然后创建的3

复制因子的话题卡夫卡将负责维护容错。

有关居然配置,在YouTube上观看这些视频进一步信息:

https://www.youtube.com/channel/UCDLPjuuYHxPbHdN8RXxrGdw

+1

对不起ü误会是错误的。顺便说一句,情况并非如此。我有跨多个节点的单个群集,目前我在每个节点上运行一个代理实例。我有一个5的复制因子,它是完全正确的。假设如果整个集群都关闭了,我不想松散数据/生产者,消费者等待。因此,我打算复制到另一个DC。最终,我想增加生产者和消费者的可用性。希望你明白这个问题。 –

相关问题