Kafka 如何從指定時間開始消費Topic

0.10.1.1版本的kafka增加了時間索引檔案，可以根據指定的時間戳計算出的offset來訪問topicpartition中的訊息。

public

class
timestampoffsetconsumer
consumer.
assign
(topicpartitions)
;// 獲取每個partition乙個小時之前的偏移量
mapmap = consumer.
offsetsfortimes
(timestampstosearch)
; 
offsetandtimestamp offsettimestamp = null;
system.out.
println
("開始設定各分割槽初始偏移量...");
for(map.entry
entry : map.
entryset()
)}system.out.
println
("設定各分割槽初始偏移量結束...");
while
(true)}
}catch
(exception e)
finally
}}

mysql 指定時間 MySQL查詢指定時間的資料

mysql查詢指定時間的資料 user event 使用者事件表 create time 表中儲存時間的字段 獲取當月資料 select from user event where date format create time,y m date format now y m 獲取3月份資料 sel...

crontab指定時間

使用crontab你可以在指定的時間執行乙個shell指令碼或者一系列linux命令。例如系統管理員安排乙個備份任務使其每天都執行 如何往 cron 中新增乙個作業?crontab e 0 5 root bin backup.sh 這將會在每天早上5點執行 root bin backup.sh cr...

Linux sleep 延遲指定時間

用途說明 sleep命令常用於在shell指令碼中延遲時間。常用方式 注意 以下用法中 可以為小數。格式 sleep 格式 sleep s 延遲秒。格式 sleep m 延遲分鐘。格式 sleep h 延遲小時。格式 sleep d 延遲天。使用示例 示例一 root jfht date sleep...