开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

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

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

展开
收起
真的很搞笑 2023-11-30 13:10:52 87 0
2 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    是的,你理解得对。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
    
    2023-11-30 22:23:25
    赞同 展开评论 打赏
  • 目前看是这样,只能增,不能减,此回答整理自钉群“【③群】Apache Flink China社区”

    2023-11-30 21:48:11
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载