1.概述

有这么一种情况，假设你的flink任务在运行中，但是，因为某一个时刻，日志突然暴增，但是你的数据又不是特别重要的，比如日志数据，但是你的分析结果又需要实时性，此时可以丢弃一些数据，让数据保持实时，但是最好是flink任务不重启，该怎么做呢？

参考：

【Kafka】Kafka 修改某个消费组的偏移量相关推荐

聊聊 Kafka：如何避免消费组的 Rebalance
一.前言我们上一篇聊了 Rebalance 机制,相信你对消费组的重平衡有个整体的认识.这里再简单回顾一下,Rebalance 就是让一个 Consumer Group 下所有的 Consumer ...
【kafka】kafka 建立很多很多消费组会怎么样
本文为博主九师兄(QQ:541711153 欢迎来探讨技术)原创文章,未经允许博主不允许转载.有问题可以先私聊我,本人每天都在线,会帮助需要的人. 文章目录 1.概述 1.概述这个问题与问题:[ka ...
【kafka】Kafka 2.3 空消费组延时rebalance
1.概述参考: https://www.cnblogs.com/huxi2b/p/6815797.html 2.什么是空消费组 3.怎么复现? 4.源码解析
【kafka】kafka 如何删除清除消费组信息
本文为博主九师兄(QQ:541711153 欢迎来探讨技术)原创文章,未经允许博主不允许转载. 文章目录 1.概述 2. 案例 2.1 测试1 2.2 测试2 2.3 测试3 M.扩展 1.概述位移 ...
【Kafka】Kafka 如果动态不停止的情况下修改消费组 offset
文章目录 1.概述 2.方案1 3.方案2 1.概述测试点:有人遇到这样的情况,他一个消费者正在消费一个环境的topic,然后他想启动另外一个消费组,但是是使用了同一个消费组,这个去更改消费组of ...
【Flink】Flink 运行实时修改消费组offset
文章目录 1.概述 3.2 flink 测试 3.3 普通测试 3.3 flink 再次测试本文为博主九师兄(QQ:541711153 欢迎来探讨技术)原创文章,未经允许博主不允许转载. 1.概述 ...
kafka专题：kafka的Topic主题、Partition分区、消费组偏移量offset等基本概念详解
文章目录 1. kafka集群整体架构 2. kafka相关元素的基本概念 2.1 主题Topic和分区Partition 2.2 kafka消息存储在哪里? 2.3 分区副本 2.4 消费组和偏移量 ...
kafka消费组查看和删除
生产环境监控发现kafka存在大量消费组查看消费组信息: ./kafka-consumer-groups.sh --bootstrap-server ip:port --list 查看特定消费组信息 ...
如何删除kafka消费组
当一个topic写入到kafka,而我们接入了多了个消费组,这种情况下,其中某个消费组停止消费,却会看到对应消费组的消息堆积依然在叠加,这是个奇怪的问题,暂时不知道什么原因,不过可以通过如下方式,将这 ...

【Kafka】Kafka 修改某个消费组的偏移量

文章目录

1.概述

【Kafka】Kafka 修改某个消费组的偏移量相关推荐

最新文章

热门文章