码迷,mamicode.com
首页 >  
搜索关键字:slow consumer handling    ( 2946个结果
js async04
function resolveAfter2Seconds() { console.log('slow start at: ' + new Date().getSeconds()) return new Promise(resolve => { setTimeout(() => { resolve( ...
分类:Web程序   时间:2020-01-16 12:23:27    阅读次数:74
js async06
1 function resolveAfter2Seconds() { 2 console.log('slow start at: ' + new Date().getSeconds()) 3 return new Promise(resolve => { 4 setTimeout(() => { ...
分类:Web程序   时间:2020-01-16 12:16:06    阅读次数:72
RocketMQ(四)——消息重试
文章目录 一、 Producer端重试 二、 Consumer端重试 1. Exception 2. Timeout总结 对于MQ,可能存在各种异常情况,导致消息无法最终被Consumer消费掉,因此就有了消息失败重试机制。很显示,消息重试分为2种:Producer端重试和Consumer端重试。 ...
分类:其他好文   时间:2020-01-15 19:11:14    阅读次数:95
面向对象总结
class Saler: def __init__(self,name,sex,ident): self.name = name self.sex = sex self.ident = ident def sale(self): print('%s卖东西'%self.name) def add_go ...
分类:其他好文   时间:2020-01-15 13:39:52    阅读次数:63
纽约比加州时间早3个小时
New York is 3 hours ahead of California, but it does not make California slow. 纽约时间比加州时间早三个小时,但加州时间并没有变慢。 Someone graduated at the age of 22, but wait ...
分类:其他好文   时间:2020-01-14 09:22:14    阅读次数:76
mysql-CPU使用率高处理
1.通过show processlist;或show full processlist;命令查看当前执行的查询 2.杀掉该进程 mysql kill 19 3.通过慢查询日志找到具体的sql语句 开启慢查询: [mysqld] slow_query_log=1 开启慢查询 long_query_ti ...
分类:数据库   时间:2020-01-13 20:03:00    阅读次数:125
Spring纯Java配置集成kafka
KafkaConfig.java package com.niugang.config; import java.util.HashMap; import java.util.Map; import org.apache.kafka.clients.consumer.ConsumerConfig; ...
分类:编程语言   时间:2020-01-13 14:33:55    阅读次数:107
(04)使用kafka脚本发送消息和接收消息
kafka的bin目录下有很多脚本,其中kafka-console-producer.sh是生产者脚本、kafka-console-consumer.sh是消费者脚本,下面用这两个脚本进行模拟发送消息和接收消息。在前面的3篇中已经介绍了kafka的配置。按照步骤启动zookeeper和kafka。 ...
分类:其他好文   时间:2020-01-12 22:18:30    阅读次数:129
Kafka 消息的消费原理
https://www.cnblogs.com/huxi2b/p/6061110.html 1.老版本的kafka的offset是维护在zk上的,新版本的kafka把consumer的offset维护保存在kafka的内部topic上 bin/kafka-simple-consumer-shell. ...
分类:其他好文   时间:2020-01-12 20:24:17    阅读次数:94
Dictionaries and Sets
1. Handling missing keys with setdefault import sys import re WORD_RE = re.compile('\w+') index = {} print(sys.argv) # Example 3-2 with open(sys.argv[ ...
分类:其他好文   时间:2020-01-12 09:40:44    阅读次数:86
2946条   上一页 1 ... 37 38 39 40 41 ... 295 下一页
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!