一、当前配置 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
20182316胡泊 2019 2020 1 《数据结构与面向对象程序设计》第6周学习总结 教材学习内容总结 第九章:多态 多态 定义:同一个变量,在不同时刻可以有不同的类型,这种性质叫做多态。 实现:一般通过继承实现,即具有多态性质的变量,只能是可相容的变量类型,而父类与子类恰好满足这个条件。(i ...
分类:
其他好文 时间:
2019-10-15 21:15:15
阅读次数:
119
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
参考:https://docs.spring.io/spring-boot/docs/1.5.4.RELEASE/reference/htmlsingle/#boot-features-error-handling spring boot 提供了默认的/error路径,并展示一个全局的错误页面。 以 ...
分类:
编程语言 时间:
2019-10-11 20:00:55
阅读次数:
85
最近遇到一个kafka方面的问题,大致就是由于consumer处理业务超时,导致无法正常提交Offset,进而导致无法消费新消息的问题。下面我想从以下几个方面对此次故障排查进行复盘分析:业务背景、问题描述、排查思路、经验教训。
分类:
其他好文 时间:
2019-10-09 19:22:43
阅读次数:
1356