function resolveAfter2Seconds() { console.log('slow start at: ' + new Date().getSeconds()) return new Promise(resolve => { setTimeout(() => { resolve( ...
分类：
Web程序 时间：
2020-01-16 12:23:27
阅读次数：
74
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
文章目录 一、 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
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
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
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
kafka的bin目录下有很多脚本，其中kafka-console-producer.sh是生产者脚本、kafka-console-consumer.sh是消费者脚本，下面用这两个脚本进行模拟发送消息和接收消息。在前面的3篇中已经介绍了kafka的配置。按照步骤启动zookeeper和kafka。 ...
分类：
其他好文 时间：
2020-01-12 22:18:30
阅读次数：
129
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
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
