且通过 DelayQueue推进时间又显著减少了时间的“空推进”，减少无故空耗机器的性能资源，通过以少量空间换时间做到“时间轮按照上述的方式运转，但是可以看到该时间轮的时间范围（interval）是有限的（tickMs*wheelSize），如果任务的延时超过了该时间范围（interval），如此时要插入一个延时为350ms的任务，则涉及到了。，而每一层时间轮的 wheelSize 是固定的，都是

一. SpringCloud组件的升级与替换过去两年里,由于SpringCloud Netflix原先的一些组件进入停更维护状态，因此这些组件逐渐被一些新技术所替代项目替换前替换后服务注册中心EurekaZookeeper、Consul、Nacos（推荐）配置中心ConfigNacos服务总线BusNacos负载均衡RibbonLoadBalancer服务调用FeignOpenFeign、Dubb

leader epoch 代表 leader 的纪元信息，初始值为0，每当 leader 变更一次， leader epoch 的值就会加1，相当于为 leader 增设了一个版本号。数据在主从复制的过程中难免会遇到某一节点宕机的情况，如何确保在类似特殊情况下依旧保持各副本数据的一致性，是分布式系统必须要解决的问题。前面提到了，Kafka采用了主写主读的方式，副本仅仅提供了数据容错功能，为什么 K

那么就会有越来越多的消息得不到及时的消费造成延迟。因此，可以采用多线程的方式来提高消费者的整体消费能力。使用该方式实现，一般所有的消费线程都属于同一个消费者组，一个消费线程可以消费一个或多个分区中的消息，因此。KafkaConsumer 非线程安全不意味着在消费消息的时候只能以单线程的方式执行，如果。的方式来获取当前 KafkaConsumer 的使用权，如果获取不到则抛异常。此外，如果需要手动提

如果消费者先处理消息后提交位移，那么如果在消息处理之后在位移提交之前消费者宕机了，那么重新上线后，会从上一次位移提交的位置拉取，这就导致了重复消息，对应 at least once。反过来，如果先提交位移后处理消息，就有可能会造成消息的丢失，对应 at most once。设置为 true即可（默认为false），开启后生产者就会幂等的发送消息。Kafka提供了幂等机制，只需显式地将生产者客户端参