当前位置: 首页 > 知识库问答 >
问题:

删除主题级别配置

盖和洽
2023-03-14

为了删除主题中的所有数据,我将主题的retention.ms配置设置为1000。

./bin/kafka-topics.sh --zookeeper $KAFKAZKHOSTS --alter --topic <topic> --config retention.ms=1000

这很管用。经过很短的等待,所有的数据都被删除了。

./bin/kafka-topics.sh --zookeeper $KAFKAZKHOSTS --alter --topic <topic> --config retention.ms=
./bin/kafka-topics.sh --zookeeper $KAFKAZKHOSTS --alter --topic <topic> --config retention.ms=null

我知道kafka-topics.sh的delete选项实际上会删除整个主题,所以我不打算玩这个。

问题:如何完全删除主题级配置,使主题恢复到使用服务器默认值?

共有1个答案

姚正真
2023-03-14

要删除主题配置重写,可以使用kafka-config工具。例如:

./bin/kafka-configs.sh --zookeeper <zookeeper> --alter \
  --entity-type topics --entity-name <topic> --delete-config retention.ms
 类似资料:
  • 我们在堆栈中使用Kafka、Kafka连接和模式注册表。版本为2.8.1(融合6.2.1)。我们使用Kafka connect的配置(key.converter和value.converter),其值为:io.confluent.connect.avro.AvroConverter。 它自动注册主题的新模式。但有一个问题,AvroConverter没有为新模式指定主题级兼容性,当我们试图通过RES

  • 我在Google Play控制台上发布了一些一年多以前的旧APK,它们的目标API级别为9-13。同一应用程序的较新版本的目标API级别更高。 我想删除对旧应用程序版本的支持,我们的REST API将不再支持这些版本。我们几乎没有人使用这些旧版本的应用程序。 但是我找不到从商店中取消发布这个旧APK的方法。是否没有办法删除旧的APK并禁用旧API级别的下载?

  • 我使用此实体表示具有自关系的类别系统,以获取子类别: 问题是当我想删除一个有子类别的类别时。我想删除所有子类别,但Java会删除此异常: 无法删除或更新父行:外键约束失败(,约束外键()引用) 我试图改变一些东西,如孤儿移除=真或级联=CascadeType。删除或尝试将级联放在单独的注释中,但不起作用。 我最后的希望是手动递归删除类别child,但这不是正确的方法。 提前感谢:)

  • 但是,这将导致以下消息: 如何删除此主题?

  • 我想删除所有空的Kafka主题(定期从cron)。我在文档中找不到一个这样做的命令?转到脚本: 但是,这包括已经过期的消息?在不使用消费者的情况下,如何在主题中找到实际的当前计数?

  • 我有几个Kafka的题目作为测试。现在我想通过清理我的Kafka主题列表来把它们全部除掉。我设置了变量,然后停止并重新启动zookeeper和kafka服务器。但什么也帮不了我。主题仍然存在,“标记为删除”。我读了这个问题,但没有找到任何答案。否则,这里建议手动移除任何主题。但我该怎么做呢?在故事的结尾,手动或通过命令行,我如何永久删除Kafka主题?