sanmutongzi

LV1
发表了文章

记一次kafka客户端NOT_COORDINATOR_FOR_GROUP处理过程

转发请注明原创地址:https://www.cnblogs.com/dongxiao-yang/p/10602799.html

sanmutongzi
KafkaNATNAT 网关
发表了文章

flink on yarn部分源码解析

转发请注明原创地址:https://www.cnblogs.com/dongxiao-yang/p/9403427.html

sanmutongzi
大数据YarnNode.js
发表了文章

spark-streaming-kafka-0-10源码分析

转发请注明原创地址http://www.cnblogs.com/dongxiao-yang/p/7767621.html

sanmutongzi
Kafkaspark文件存储
发表了文章

flink-connector-kafka consumer checkpoint源码分析

转发请注明原创地址:http://www.cnblogs.com/dongxiao-yang/p/7700600.html

sanmutongzi
Kafka大数据HTTP
发表了文章

GroupCoordinator joingroup源码解析

转发请注明原创地址 http://www.cnblogs.com/dongxiao-yang/p/7463693.html

sanmutongzi
HTTPHTML
发表了文章

storm RollingTopWords 实时top-N计算任务窗口设计

转发请注明原创地址 http://www.cnblogs.com/dongxiao-yang/p/6381037.html

sanmutongzi
WindowsPython
发表了文章

PriorityBlockingQueue优先队列的二叉堆实现

转载请注明原创地址http://www.cnblogs.com/dongxiao-yang/p/6293807.html

sanmutongzi
编程算法Java
发表了文章

堆排序算法的java实现

堆积排序(Heapsort)是指利用堆积树(堆)这种数据结构所设计的一种排序算法,可以利用数组的特点快速定位指定索引的元素。堆排序是不稳定的排序方法,...

sanmutongzi
HTTP编程算法
发表了文章

kafka consumer 分区reblance算法

转载请注明原创地址 http://www.cnblogs.com/dongxiao-yang/p/6238029.html

sanmutongzi
Kafka
发表了文章

btrace 笔记

转载请注明原链接地址 http://www.cnblogs.com/dongxiao-yang/p/6134393.html

sanmutongzi
Java
发表了文章

【转载】Storm TickTuple 意外停止

原文链接转自:http://woodding2008.iteye.com/blog/2328114

sanmutongzi
Kafka
发表了文章

【转载】nginx 并发数问题思考:worker_connections,worker_processes与 max clients

注:这个文章主要是作者一直在研究nginx作为http server和反向代理服务器时候所谓最大的max_clients和 worker_connections...

sanmutongzi
HTTP网络安全网站Nginx
发表了文章

【转载】运维小技巧:使用ss命令代替 netstat

顾名思义,ss命令可以用来获取socket统计信息,它可以显示和netstat类似的内容。但ss的优势在于它能够显示更多更详细的有关TCP和连接状态的信息,而且...

sanmutongzi
TCP/IPHTTPSocket编程HTML
发表了文章

zookeeper 删除snapshot和transaction log的源码解读

转载请注明源地址http://www.cnblogs.com/dongxiao-yang/p/4910059.html

sanmutongzi
编程算法C++Java数据结构ActionScript
发表了文章

为什么要使用SLF4J而不是Log4J

本文由 ImportNew - Jaskey 翻译自 javarevisited。欢迎加入翻译小组。转载请见文末要求。

sanmutongzi
面向对象编程API编程算法日志服务Apache
发表了文章

Hive 创建和生成Rcfile 和SequenceFile格式的表

rcfile格式表需要从原始的textfile 文件格式表导出数据并导入到新建好的rcfile格式表里

sanmutongzi
编程算法TCP/IPSQLBashBash 指令
发表了文章

sparkstreaming的状态计算-updateStateByKey源码

转发请注明原创地址:https://www.cnblogs.com/dongxiao-yang/p/11358781.html

sanmutongzi
spark批量计算Java
发表了文章

java.util.concurrent 包笔记 --- BlockingQueue

队列接口,具有 4 组不同的方法用于插入、移除以及对队列中的元素进行检查。如果请求的操作不能得到立即执行的话,每个方法的表现也不同。这些方法如下:

sanmutongzi
编程算法
发表了文章

kafka default partitioner java版本和scala版本的不同

sanmutongzi
Kafka
发表了文章

kafka rebalance 部分分区没有owner

转发请注明原创地址http://www.cnblogs.com/dongxiao-yang/p/6234673.html

sanmutongzi
Kafka

个人简介

个人成就

扫码关注云+社区

领取腾讯云代金券