【问题标题】:Create duplicate topic in kafka using python使用python在kafka中创建重复主题
【发布时间】:2022-02-04 22:35:50
【问题描述】:

有没有一种方法可以使用 kafka-python 包创建 kafka 主题的副本?我正在尝试在对数据执行一些操作之前创建主题的备份。

【问题讨论】:

    标签: python apache-kafka kafka-python


    【解决方案1】:

    如果不将整个内容作为二进制数据使用,然后将其写回,则无法备份主题。理想情况下,你会为​​此使用 MirrorMaker 之类的东西(内置于 Kafka)而不是 Python

    不清楚你需要执行哪些操作,但是主题中的数据是不可变的,所以你所做的任何事情都不会改变它

    否则,是的,您可以使用 AdminClient API 以编程方式创建/删除主题,以便在将另一个主题“备份”到其中之前“使用设置复制主题”

    【讨论】:

      猜你喜欢
      • 2018-03-31
      • 1970-01-01
      • 2017-04-19
      • 2018-10-11
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多