腾讯云开发者社区-腾讯云

开发者社区

文档建议反馈控制台

最新优惠活动

文章/答案/技术大牛

发布

stream process

专栏作者

76

文章

92837

阅读量

15

订阅数

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

kafka nat NAT 网关

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

2020-03-05

1.4K0

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

kafka spark 文件存储

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

2020-03-05

6860

flink-connector-kafka consumer checkpoint源码分析

kafka 大数据 http

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

2020-03-05

1K0

kafka consumer 分区reblance算法

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

2020-03-05

4350

【转载】Storm TickTuple 意外停止

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

2020-03-05

5650

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

7170

kafka rebalance 部分分区没有owner

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

2020-03-04

8830

spark-streaming-kafka包源码分析

kafka 编程算法 java spark

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

2020-03-04

5980

kafka 部分问题处理记录

kafka scala hashmap 日志服务批量计算

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

2020-03-04

1.3K0

kafka consumer assign 和 subscribe模式差异分析

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

2020-03-04

2.5K1

flink-connector-kafka consumer的topic分区分配源码

kafka 大数据 actionscript 面向对象编程

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

2020-03-04

9150

kafka 配置kerberos校验以及开启acl实践

kafka scala kerberos bash bash 指令

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

2020-03-04

2.3K0

storm spout的速度抑制问题

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

2020-03-04

5500

kafka leader 服务器均衡。

Whenever a broker stops or crashes leadership for that broker's partitions transfers to other replicas. This means that by default when the broker is restarted it will only be a follower for all its partitions, meaning it will not be used for client reads and writes.

2020-03-04

5980

kafka集群扩容以及数据迁移

kafka zookeeper json bash bash 指令

一 kafka集群扩容比较简单，机器配置一样的前提下只需要把配置文件里的brokerid改一个新的启动起来就可以。比较需要注意的是如果公司内网dns更改的不是很及时的话，需要给原有的旧机器加上新服务器的host，不然可能会产生controller服务器从zk上拿到域名但是解析不到新机器地址的情况。

2020-03-04

9490

kafka offset-check工具失效的问题

kafka bash bash 指令 http 编程算法

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

2020-03-04

5250

kafka broker 进入 conflicted ephemeral node 死循环

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

2020-03-04

1K0

kafka Disks and Filesystem（磁盘和文件系统）

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

2020-03-04

3580

flumeng-kafka-plugin

kafka 数据库一体机 TData github 编程算法 git

github 参考地址：https://github.com/beyondj2ee/flumeng-kafka-plugin/tree/master/flumeng-kafka-plugin

2020-03-04

3160

没有更多了

社区活动

RAG七天入门训练营

鹅厂大牛手把手带你上手实战

Python精品学习库

代码在线跑，知识轻松学

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

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

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

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