我们知道，在目前微服务中，众多的微服务调用关系错综负责，为了维护系统的稳定，引入了限流、降级、熔断等概念，这其中比较出名的是Hystrix和Sentinel，来聊聊这二者的异同。

Docker中网络相关研究

在Kafka服务端中每个分区的每条消息都有唯一的offset，用来表示消息在分区中对应的位置。对于消费者客户端而言，也有一个offset，表示的是消费到分区中某个消息所在的位置。消费者客户端每次调用poll时返回的是未被消费的消息，为了能够知道哪些消息被消费过，哪些消息未被消费，消费者客户端使用offset来记录上一次消费位置。为了做到这一点，需要将消费位移进行持久化而不是简单的保存在内存中，这.

kafka消费者consumer代码示例：import org.apache.kafka.clients.consumer.ConsumerConfig;import org.apache.kafka.clients.consumer.ConsumerRecord;import org.apache.kafka.clients.consumer.ConsumerRecords;impor...

使用debezium和kafka-connect实现postgres数据库实时同步到kafka中

kafka的生产者客户端Producer是线程安全的，但是消费者客户端是非线程安全的，每次操作时都会调用accqure方法用来确定当前只有一个线程操作，如果有多个线程在操作，会抛出CME异常。针对这种情况，为了能够多线程更快速的读取消息，可以参考如下两种方式：在同一个消费者组下，每个线程建立一个consumer消费者组，这样相当于是在一个消费者组中多个消费者同时读取另外一种处理就是，用...

在 Sentinel 里面，所有的资源都对应一个资源名称以及一个 Entry。Entry 可以通过对主流框架的适配自动创建，也可以通过注解的方式或调用 API 显式创建；每一个 Entry 创建的时候，同时也会创建一系列功能插槽（slot chain）。这些插槽有不同的职责，例如:NodeSelectorSlot 负责收集资源的路径，并将这些资源的调用路径，以树状结构存储起来，用于根据调用路径来限

我们知道现在项目一般都会使用springboot作为基础框架，如果项目需要基于springboot实现自动导入的话，一般都会实现一个xxx-starter，我们看看spring-cloud-starter-alibaba-sentinel是怎么实现的。本篇有些内容需要基于之前一篇的分析Sentinel限流原理（基于Sentinel1.8.1)，限流、熔断、热点参数限流、授权实现原理springbo

我们知道，Sentinel dashboard默认是是没有持久化功能的，都是保存在内存中的，对于sentinel客户端同样如此，当在sentinel dashboard配置规则的时候，dashboard会获取对应应用配置的dashboard给应用传递消息的http，将规则通过HTTP请求发送给sentinel客户端，同样，sentinel客户端也是没有持久化的都是放在内存中的。sentinel d

本文分析Nacos基于Nacos 2.0Nacos中服务注册中心默认是AP模式，AP模式和CP模式切换可以通过请求如下接口调整curl -X PUT 'ip:port/nacos/v1/ns/operator/switches?entry=serverMode&value=CP'同时客户端设置 spring.cloud.nacos.discovery.ephemeral=false （默认