码迷,mamicode.com
首页 >  
搜索关键字:slow consumer handling    ( 2946个结果
高吞吐量的分布式发布订阅消息系统Kafka--spring-integration-kafka的应用
一、概述 Spring Integration Kafka 是基于 Apache Kafka 和Spring Integration来集成Kafka,对开发配置提供了方便。 二、配置 1、spring-kafka-consumer.xml 2、spring-kafka-producer.xml 3、 ...
分类:编程语言   时间:2016-05-02 22:44:04    阅读次数:543
dubbo源码分析-consumer端4-ClusterInvoker与LoadBalance
dubbo中提供了多种集群调用策略:         1、FailbackClusterInvoker :  失败自动恢复,后台记录失败请求,定时重发,通常用于消息通知操作;         2、FailfastClusterInvoker: 快速失败,只发起一次调用,失败立即报错,通常用于非幂等性的写操作;         3、FailoverClusterInvoker: 失败转移,当出...
分类:数据库   时间:2016-04-29 19:57:06    阅读次数:272
浅谈dubbo的ExceptionFilter异常处理
背景 我们的项目使用了dubbo进行不同系统之间的调用。 每个项目都有一个全局的异常处理,对于业务异常,我们会抛出自定义的业务异常(继承RuntimeException)。 全局的异常处理会根据不同的异常类型进行不同的处理。 最近我们发现,某个系统调用dubbo请求,provider端(服务提供方)抛出了自定义的业务异常,但consumer端(服务消费方)拿到的并不是自定义的业务异常。...
分类:其他好文   时间:2016-04-29 19:47:15    阅读次数:253
jQuery事件
1、show()显示效果 语法:show(speed,callback) Number/String,Function speend为动画执行时间,单位为毫秒。也可以为slow","normal","fast" callback可选,为当动画完成时执行的函数。 show(speed,[easing] ...
分类:Web程序   时间:2016-04-29 14:18:41    阅读次数:167
Ajax基本知识(二)
Step 2 – Handling the server response First, the function needs to check for the state of the request. If the state has the value of XMLHttpRequest.DO ...
分类:Web程序   时间:2016-04-27 20:46:39    阅读次数:169
Kafka Zookeeper 基本命令示例
装修中... Kafka 新建Topic 查看已存在Topic列表 查看指定Topic状态 启动Consumer读取消息并输出到标准输出 运行Producer并将Terminal输入的消息发送到服务端 Zookeeper ...
分类:其他好文   时间:2016-04-27 12:51:07    阅读次数:169
Kafka消费者Consumer常用配置
bootstrap.servers:broker服务器集群列表,格式为host1:port1,host2:port2key.deserializer:定义序列化的接口value.deserializer:实现序列化接口的类group.id:消费者分组Idconsumer.timeout.ms:消费者连接超时时间,默认为5000毫秒zookeeper.connect:Zookeeper服务器地址..
分类:其他好文   时间:2016-04-27 11:03:50    阅读次数:806
dubbo源码分析-consumer端4-ClusterInvoker与LoadBalance
dubbo中提供了多种集群调用策略:         1、FailbackClusterInvoker :  失败自动恢复,后台记录失败请求,定时重发,通常用于消息通知操作;         2、FailfastClusterInvoker: 快速失败,只发起一次调用,失败立即报错,通常用于非幂等性的写操作;         3、FailoverClusterInvoker: 失败转移,当出...
分类:数据库   时间:2016-04-26 21:55:52    阅读次数:215
浅谈dubbo的ExceptionFilter异常处理
背景 我们的项目使用了dubbo进行不同系统之间的调用。 每个项目都有一个全局的异常处理,对于业务异常,我们会抛出自定义的业务异常(继承RuntimeException)。 全局的异常处理会根据不同的异常类型进行不同的处理。 最近我们发现,某个系统调用dubbo请求,provider端(服务提供方)抛出了自定义的业务异常,但consumer端(服务消费方)拿到的并不是自定义的业务异常。...
分类:其他好文   时间:2016-04-26 21:45:15    阅读次数:553
[Angular 2] Handling Click Events with Subjects
While Angular 2 usually uses event handlers to manage events and RxJS typically uses Observable.fromEvent, a good practice when using Angular 2 and Rx ...
分类:其他好文   时间:2016-04-26 07:06:30    阅读次数:274
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!