1.幂等消息 为了解决重试导致的消息重复、乱序问题,kafka引入了幂等消息。幂等消息保证producer在一次会话内写入一个partition内的消息具有幂等性,可以通过重...
IP属地:天津
1.幂等消息 为了解决重试导致的消息重复、乱序问题,kafka引入了幂等消息。幂等消息保证producer在一次会话内写入一个partition内的消息具有幂等性,可以通过重...
1 上周复盘 完成工作内容复盘和分享 事务分享delay至下周 2 本周感悟 · 有些形式看似浪费时间,实际可以代表一个人的做事态度 · 成功的领导者不是自己优秀,而是能发挥...
1.背景 目前有一个kafka消费者工程,此工程会消费kafka中的消息,并通过fastjson解析该消息为java实体,然后存入到阻塞队列 BlockingQueue中。另...
Go提供了两种分配原语,即new和make。它们所做的事情是不一样的,所应用的类型也不同。 new用来分配内存,但与其他语言中的同名函数不同,它不会初始化内存,只会讲内存置零...
在golang中interface底层分析文中分析了接口的底层原理。其中接口的内部结构分两种一种是iface接口,就是有方法的接口,另一种是eface是空接口。不管是哪种都有...
结构体是一种聚合的数据类型,是由零个或多个任意类型的值聚合成的实体,每个值称为结构体的成员。下面分两方面介绍:一个是基础部分,一个是看一下结构体在实际内存中的内存模型。 1 ...
虽然Golang的GC自打一开始,就被人所诟病,但是经过这么多年的发展,Golang的GC已经改善了非常多,变得非常优秀了。 以下是Golang GC算法的里程碑: v1.1...
本文是《循序渐进go语言》第四篇-Go内存分配机制。golang的内存采用了TCMalloc 这种分配机制。go是在多种语言诞生N多年之后,才由几个大神开发的。每种语言都有自...