注:本文依賴于kafka-0.10.0.1-src 我們都知道kafka生產(chǎn)者send一條記錄(record)后并沒有直接發(fā)送到kafka服務(wù)端,而是先將它保存到內(nèi)存...
IP屬地:廣東
注:本文依賴于kafka-0.10.0.1-src 我們都知道kafka生產(chǎn)者send一條記錄(record)后并沒有直接發(fā)送到kafka服務(wù)端,而是先將它保存到內(nèi)存...
餓了么BDI-大數(shù)據(jù)平臺研發(fā)團隊目前共有20人左右,主要負(fù)責(zé)離線&實時Infra和平臺工具開發(fā)。其中6人的離線團隊需要維護大數(shù)據(jù)集群規(guī)模如下: Hadoop集群規(guī)模1300+...
delay-queue redis實現(xiàn)延遲消息隊列 需求背景 最近在做一個排隊取號的系統(tǒng) 在用戶預(yù)約時間到達前XX分鐘發(fā)短信通知 在用戶預(yù)約時間結(jié)束時要判斷用戶是否去取號了,...
先說結(jié)論:是@FrameworkController的坑 一個同事和我反饋他們的health-check接口都很慢,在容器(2核)只有1000qps不到,這讓我很想不通,he...
前言 每當(dāng)使用SpringBoot進行Weboscket開發(fā)時,最容易想到的就是spring-boot-starter-websocket(或spring-websocket...
1. 先解釋下泛型概念 泛型是Java SE 1.5的新特性,泛型的本質(zhì)是參數(shù)化類型,也就是說所操作的數(shù)據(jù)類型被指定為一個參數(shù)。這種參數(shù)類型可以用在類、接口和方法的創(chuàng)建中,分...