首页
学习
活动
专区
工具
TVP
发布

悠扬前奏的博客

专栏作者
333
文章
258177
阅读量
32
订阅数
Kafka多分区下二分法查找指定时间戳的offset
python消费Kafka的时候,不能指定时间戳开始消费,只能指定offset,因此需要先找到指定时间戳所在的offset再消费。百度找到的文章都是单分区下的查找方法,多分区时需要做一定的修改,记录下代码:
悠扬前奏
2021-11-24
7990
Kafka-3.配置-Topic Config
和主题有关的配置既有服务器的默认值,也有可选的per-topic的覆盖值。如果没有per-topic的配置值,就用服务器的默认值。覆盖值能在创建主题的时候用一个或多个--config选项来设置。以下示例用一个名为my-topic的主题,其中包含自定义最大消息大小和刷新率:
悠扬前奏
2019-06-11
1.7K0
Redis-3. 过期时间
1. 基础 Redis可以通过过期时间(expiration)特性来让一个键在给定的时限(timeout)之后自动删除。 *对于列表,集合,散列和有序集合这样的容器(container)来说,键的过期命令只能为整个键设置 2. 命令 命令 描述 PERSIST PERSIST key-name:移除键的过期时间 TTL TTL key-name:查看给定键距离过期时间还有多少秒 EXPIRE EXPIRE key-name seconds:让给定的键在指定秒数之后过期 EXPIREAT EXPIREAT
悠扬前奏
2019-05-31
1K0
Java并发-23.Fork/Join框架
什么是Fork/Join框架 Fork把一个大任务切分成若干个子任务 Join把子任务的执行结果合并 工作窃取算法 是什么:某个线程从其他队列窃取任务来执行。 双端队列实现,被窃取任务线程从头部拿任务执行,窃取任务线程从尾部拿任务执行 优点:充分利用线程并行计算,减少线程竞争 缺点:某些情况下存在竞争,消耗更多的系统资源 框架设计 ForkJoinTask:创建ForkJoin任务,用于分割一般不需要直接继承它,而是继承它的子类: RecursiveAction:没有返回结果的任务 Recursiv
悠扬前奏
2019-05-31
3100
LeetCode-192. 统计词频
写一个 bash 脚本以统计一个文本文件 words.txt 中每个单词出现的频率。
悠扬前奏
2019-05-29
6700
LeetCode-194. 转置文件
第一反应是用awk显示列,那么需要知道有多少列。就先用awk获取列数,再循环。应该这个答案缓存击败100%用户,但是用时击败4.02%,显然耗时有点多,需要改进。
悠扬前奏
2019-05-29
5000
MySql时间函数
同now()函数不同的是,now()在执行开始时得到,sysdate()在函数执行时动态得到。
悠扬前奏
2019-05-28
5.1K0
没有更多了
社区活动
腾讯技术创作狂欢月
“码”上创作 21 天,分 10000 元奖品池!
Python精品学习库
代码在线跑,知识轻松学
博客搬家 | 分享价值百万资源包
自行/邀约他人一键搬运博客,速成社区影响力并领取好礼
技术创作特训营·精选知识专栏
往期视频·千货材料·成员作品 最新动态
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档