【发布时间】:2022-02-04 22:35:50
【问题描述】:
有没有一种方法可以使用 kafka-python 包创建 kafka 主题的副本?我正在尝试在对数据执行一些操作之前创建主题的备份。
【问题讨论】:
标签: python apache-kafka kafka-python
有没有一种方法可以使用 kafka-python 包创建 kafka 主题的副本?我正在尝试在对数据执行一些操作之前创建主题的备份。
【问题讨论】:
标签: python apache-kafka kafka-python
如果不将整个内容作为二进制数据使用,然后将其写回,则无法备份主题。理想情况下,你会为此使用 MirrorMaker 之类的东西(内置于 Kafka)而不是 Python
不清楚你需要执行哪些操作,但是主题中的数据是不可变的,所以你所做的任何事情都不会改变它
否则,是的,您可以使用 AdminClient API 以编程方式创建/删除主题,以便在将另一个主题“备份”到其中之前“使用设置复制主题”
【讨论】: