flink自动发现kafka新增分区

如果flink程序在运行中,kafka新增了分区,flink程序是消费不了的,需要重启flink程序,然后重置kafka的offset

./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group my_consumer_group --topic my_topic --reset-offsets --to-earliest --execute

设置flink自动发现kafka新增分区:

相关推荐

  1. flink自动发现kafka新增分区

    2024-01-10 19:52:03       40 阅读
  2. Kafka分区数扩容 Flink发现分区

    2024-01-10 19:52:03       21 阅读
  3. GaussDB分区自动新增分区

    2024-01-10 19:52:03       21 阅读
  4. 【大数据】gRPC、FlinkKafka 分别是什么?

    2024-01-10 19:52:03       6 阅读
  5. Flink mongo & Kafka

    2024-01-10 19:52:03       7 阅读

最近更新

  1. TCP协议是安全的吗?

    2024-01-10 19:52:03       19 阅读
  2. 阿里云服务器执行yum,一直下载docker-ce-stable失败

    2024-01-10 19:52:03       19 阅读
  3. 【Python教程】压缩PDF文件大小

    2024-01-10 19:52:03       19 阅读
  4. 通过文章id递归查询所有评论(xml)

    2024-01-10 19:52:03       20 阅读

热门阅读

  1. OceanBase CentOS7集群部署

    2024-01-10 19:52:03       44 阅读
  2. 面试 React 框架八股文十问十答第四期

    2024-01-10 19:52:03       38 阅读
  3. MySQL面试题(下)

    2024-01-10 19:52:03       33 阅读
  4. 面试 React 框架八股文十问十答第一期

    2024-01-10 19:52:03       40 阅读
  5. glusterFS

    glusterFS

    2024-01-10 19:52:03      34 阅读
  6. linux系统关于nginx服务

    2024-01-10 19:52:03       42 阅读
  7. 修改 Git 仓库的远程地址

    2024-01-10 19:52:03       37 阅读
  8. C#语言练手小功能

    2024-01-10 19:52:03       37 阅读
  9. 计算几何学(工程版)

    2024-01-10 19:52:03       40 阅读