golang 实现kafka延迟队列

Flag

基于github.com/Shopify/sarama v1.26.1 版本很重要 与 v1.24.1有很大不同
golang 实现的Kafka 延迟队列没有找到，自己弄个；

先开个头

const (
	second          = 1
	minute          = 60 * second
	hour            = 60 * minute
	sleepBaseSecond = 5 // 5s 不能太长，grateful stop sleep

	// 不少于5s的延迟
	// delay5s  = 5 * second
	// delay10s = 10 * second
	// delay30s = 30 * second
	// delay1m  = 1 * minute
	// delay2m  = 2 * minute
	// delay3m  = 3 * minute
	// delay5m  = 5 * minute
	// delay10m = 10 * minute
	// delay15m = 15 * minute
	// delay20m = 20 * minute
	// delay30m = 30 * minute
	delay1h = 1 * hour
	// delay2h  = 2 * hour
	// delay1h = 3 * hour
	// delay5h  = 5 * hour
	// delay12h = 12 * hour
)

直接github吧 ，有时间直接上代码；

https://github.com/asppj/delay-queue