fetch.min.bytes. #获取最小字节数据 Consumer 向broker中要数据时是按大小来返回的，如果数据没有达到指定的M数，consumer会处于等待状态，直到broker 从producer 哪里获取到指定大小的数据为止。获取取的最小数据大小是指的每个partition上的数据。... ...
分类：
其他好文 时间：
2019-07-10 01:05:01
阅读次数：
105
Google put the method to extract different featurebased on Slow Network and Fast Network The First Colum | The Second Column : :|: : innovation point1 ...
分类：
其他好文 时间：
2019-07-07 12:23:21
阅读次数：
128
最近看到代码中有语法糖，记录一下， 1.重写，只能重写，属性，虚方法（virtual）,子类重写用override private string apublic string A{get =>“123”；set =>a=value;} 2.定义静态变量赋值 private static Lazy<K ...
rocketMq建立监听： 一个groupId下通常会挂载多个consumer实例。 集群订阅方式 (默认)：一个监听到之后，另一个consumer实例就不会再监听到（不管在不在一个服务器上）。 由于默认集群订阅方式，只能有一个监听到，所以，本地测试和服务器上topic不能一致，否则会影响服务器上监 ...
分类：
其他好文 时间：
2019-07-04 21:28:58
阅读次数：
163
题目描述 输入一个链表，输出该链表中倒数第k个结点。 思路 设置两个指针 fast 、slow，fast先走k-1步，然后再一起走； 先走的k-1步中，如果遇到fast=nullptr，说明链表长度小于k-1，就没有倒数第k项，那就直接返回空指针； 当fast走到最后一个结点，slow恰好在倒数第k ...
分类：
其他好文 时间：
2019-07-04 14:32:41
阅读次数：
92
1.如何定位并优化慢查询sql a.根据慢日志定位慢查询sql SHOW VARIABLES LIKE '%query%' 查询慢日志相关信息 slow_query_log 默认是off关闭的，使用时，需要改为on 打开 slow_query_log_file 记录的是慢日志的记录文件 long_q ...
分类：
数据库 时间：
2019-07-04 14:24:11
阅读次数：
159
1.引入jar 2.kafka producer 3.consumer ...
分类：
其他好文 时间：
2019-07-04 11:24:00
阅读次数：
75
系统运维的过程中，每一个细节都值得我们关注 下图为我们的基本日志处理架构 所有日志由Rsyslog或者Filebeat收集，然后传输给Kafka，Logstash作为Consumer消费Kafka里边的数据，分别写入Elasticsearch和Hadoop，最后使用Kibana输出到web端供相关人 ...
分类：
其他好文 时间：
2019-07-04 09:27:39
阅读次数：
137
1、kafka的配置 2、topic的配置 3、producer的配置 4、consumer的配置 props.put("consumer.timeout.ms", "100"); 这个配置很重要，关乎取消息的阻塞的时间 默认-1,consumer在没有新消息时无限期的block。如果设置一个正值， ...
分类：
其他好文 时间：
2019-07-02 13:29:18
阅读次数：
81
RocketMQ重试机制 消息重试分为两种： Producer发送消息的重试 和 Consumer消息消费的重试 。 一、Producer端重试 Producer端重试是指: Producer往MQ上发消息没有发送成功，比如网络原因导致生产者发送消息到MQ失败。 看一下代码： 针对网上说的超时异常会 ...
分类：
其他好文 时间：
2019-07-02 00:17:20
阅读次数：
80
