Flink可以匹配正则表示可以简写topiclist,不代表可以增删topic吧?[阿里云]

Flink可以匹配正则表示可以简写topiclist,不代表可以增删topic吧?

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====
1 条回复 A 作者 M 管理员
  1. 是的,你理解得对。Apache Flink 的正则表达式匹配功能允许你在代码中使用一个简化的字符串来指定多个 Kafka 主题,而不需要显式地列出每个主题的名字。这对于动态消费场景非常有用,特别是当有新主题被创建或者旧主题被删除时。

    然而,Flink 本身并不提供直接修改或管理 Kafka 主题的功能。添加、删除和更新 Kafka 主题的操作需要通过与 Kafka 相关的工具或者 API 来完成。例如,你可以使用 kafka-topics.sh 脚本(在 Kafka 安装目录下的 bin 文件夹中)或者 Kafka 的 Java AdminClient API 来执行这些操作。

    以下是使用 kafka-topics.sh 脚本来创建和删除主题的示例:

    # 创建一个名为 "my-topic" 的主题,具有1个分区和3个副本./kafka-topics.sh --create --topic my-topic --partitions 1 --replication-factor 3 --bootstrap-server localhost:9092# 删除名为 "my-topic" 的主题./kafka-topics.sh --delete --topic my-topic --bootstrap-server localhost:9092
  2. 目前看是这样,只能增,不能减,此回答整理自钉群“【③群】Apache Flink China社区”