stream process-腾讯云开发者社区

开发者社区

文档建议反馈控制台

腾讯云架构师技术同盟

文章/答案/技术大牛

发布

stream process

专栏成员

76

文章

98455

阅读量

15

订阅数

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

kafka nat NAT 网关

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

2020-03-05

1.6K0

flink on yarn部分源码解析

大数据 yarn node.js

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

2020-03-05

1K0

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

kafka spark 文件存储

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

2020-03-05

7420

flink-connector-kafka consumer checkpoint源码分析

kafka 大数据 http

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

2020-03-05

1.1K0

GroupCoordinator joingroup源码解析

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

2020-03-05

8180

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

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

2020-03-05

5390

PriorityBlockingQueue优先队列的二叉堆实现

编程算法 java

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

2020-03-05

5080

堆排序算法的java实现

http 编程算法

堆积排序(Heapsort)是指利用堆积树（堆）这种数据结构所设计的一种排序算法，可以利用数组的特点快速定位指定索引的元素。堆排序是不稳定的排序方法，辅助空间为O(1)，最坏时间复杂度为O(nlog2n) ，堆排序的堆序的平均性能较接近于最坏性能。

2020-03-05

6750

kafka consumer 分区reblance算法

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

2020-03-05

4680

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

2020-03-05

4200

【转载】Storm TickTuple 意外停止

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

2020-03-05

6250

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

http 网络安全网站 nginx

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

2020-03-05

2.6K0

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

tcp/ip http socket编程 html

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

2020-03-05

1.5K0

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

编程算法 c++java 数据结构 actionscript

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

2020-03-05

7040

为什么要使用SLF4J而不是Log4J

面向对象编程 api 编程算法日志服务 apache

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

2020-03-05

6810

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

编程算法 tcp/ip sql bash bash 指令

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

2020-03-05

1.5K0

sparkstreaming的状态计算-updateStateByKey源码

spark 批量计算 java

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

2020-03-04

3900

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

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

2020-03-04

3810

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

scala import kafka.utils._ class DefaultPartitioner(props: VerifiableProperties = null) extends Partitioner { private val random = new java.util.Random def partition(key: Any, numPartitions: Int): Int = { Utils.abs(key.hashCode) % numPartitions

2020-03-04

7400

kafka rebalance 部分分区没有owner

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

2020-03-04

9140

点击加载更多

社区活动

Python精品学习库

代码在线跑，知识轻松学

博客搬家 | 分享价值百万资源包

自行/邀约他人一键搬运博客，速成社区影响力并领取好礼

技术创作特训营·精选知识专栏

往期视频·干货材料·成员作品最新动态