为什么读RocketMQ 消息队列在互联网应用中使用较为广泛，学习她可以让我门更加了解使用技术的工作原理 透过学习她的源码，拓宽认知 RocketMQ经历了阿里双十一 有哪些名词 Producer 消息生产者，负责产生消息 Consumer 消息消费者，负责消费消息 Producer Group 一 ...
分类：
其他好文 时间：
2019-10-20 17:36:01
阅读次数：
88
Sematext Monitoring 是最全面的Kafka监视解决方案之一，可捕获约200个Kafka指标，包括Kafka Broker，Producer和Consumer指标。尽管其中许多指标很有用，但每个人都有一个要监视的特定指标–消费者滞后。 什么是卡夫卡消费者滞后？ 卡夫卡消费者滞后指标表 ...
分类：
其他好文 时间：
2019-10-17 15:43:04
阅读次数：
97
import org.junit.Test; import java.util.ArrayList; import java.util.Arrays; import java.util.List; import java.util.function.Consumer; import java.uti... ...
分类：
编程语言 时间：
2019-10-17 15:28:01
阅读次数：
104
一、当前配置 Flink：版本1.4 Flink-Kafka-Connector：0.10.x Kafka-Brokers:3个 Topic-Partitoins:3个 Topic-Replication:2个 二、现象描述 Flink通过Kafka-Connector连接Kafka消费数据，当Ka ...
分类：
其他好文 时间：
2019-10-16 20:12:42
阅读次数：
174
dubbo推荐在Provider上尽量多配置Consumer端属性： 由服务提供方设置超时，因为一个方法需要执行多长时间，服务提供方更清楚，如果一个消费方同时引用多个服务，就不需要关心每个服务的参数设置； 在Provider配置后，Consumer不配置则会使用Provider的配置值，即Provi ...
分类：
其他好文 时间：
2019-10-16 09:56:36
阅读次数：
124
java.rmi.UnmarshalException: error unmarshalling return; nested exception is:
java.lang.ClassNotFoundException: XXX (no security manager: RMI class ... ...
分类：
编程语言 时间：
2019-10-16 09:54:25
阅读次数：
83
Eureka Provider 服务的提供者 新建一个服务提供者项目 1、导入pom文件 2、在启动类上加注解 上边那个@EnableDiscoverClient 注解加不加都行的原因会在后边表名 3、在Eureka Provider项目中添加一个简单的接口 4、以上配置完成之后启动Eureka P ...
分类：
编程语言 时间：
2019-10-16 00:46:32
阅读次数：
108
Springcloud中的region和zone的使用 一、背景 用户量比较大或者用户地理位置分布范围很广的项目，一般都会有多个机房。这个时候如果上线springCloud服务的话，我们希望一个机房内的服务优先调用同一个机房内的服务 ，当同一个机房的服务不可用的时候，再去调用其它机房的服务，以达到减 ...
分类：
编程语言 时间：
2019-10-16 00:29:11
阅读次数：
108
Exclusive Consumer: 独有消费者：Queue中的消息是按照顺序被分发到consumer的，然而，当你有多个consumers同时从相同的queue中提取消息时，你将失去这个保证。因为这些消息是被多个线程并发的处理。有的时候，保证消息按照顺序处理是很重要的。例 ...
分类：
其他好文 时间：
2019-10-13 19:08:40
阅读次数：
97
错误日志： 2019-10-11 17:50:48.744 WARN []-[o.a.k.clients.consumer.ConsumerConfig :173] The configuration num.replica.fetchers = 1 was supplied but isn't a ...
分类：
移动开发 时间：
2019-10-12 10:48:11
阅读次数：
403
