1

如何添加新的订购者下载分类账作为订购节点彼此没有连接,并且kafka只保留7天的消息。排序节点同步如何工作?

而且如果我关闭一个订购者节点超过7天,如果我再次提起它,那么它将不会在kafka分区中查找那7天发生的事务,因此它将如何同步并更新它是本地的总帐。

回答

3

在1.0中,卡夫卡经纪人将被设置为log.retention.ms = -1(来源:documentation,步骤4e)。

这会禁用基于时间的保留并防止段到期。这意味着:

  1. 分区托管通道的整个事务历史记录。
  2. 可以随时添加新的订购者服务节点(OSN),并使用Kafka代理与所有通道完全同步。

在1.x轨道中的次要版本中,我们将支持对OSN进行分类帐修剪。这意味着经纪人只需要维护一个修剪后的交易历史记录序列(始终从配置块开始),任何新的OSN都只能同步回该配置块。