1.Kafka文件存储基本结构 1)在Kafka文件存储中,同一个topic下有多个不同partition,每个partition为一个目录,partiton命名规则为topic名称+有序序号,第一个partiton序号从0开始,序号最大值为partitions数量减1 2)每个partion(目录 ...
分类:
其他好文 时间:
2020-03-03 22:34:12
阅读次数:
102
什么是再平衡 所谓的再平衡,指的是在kafka consumer所订阅的topic发生变化时发生的一种分区重分配机制。一般有三种情况会触发再平衡: consumer group中的新增或删除某个consumer,导致其所消费的分区需要分配到组内其他的consumer上; consumer订阅的top ...
分类:
其他好文 时间:
2020-03-03 20:35:52
阅读次数:
86
聊聊我对 react 的理解。react 历史发展。react 性能优化。React 历史发展Jquery 时代在 jquery 主流的时代,web 页面开发流程是通过 ajax 获取到后端数据,然后使用 jquery 生成 jquery 更新到页面中,但是随着业务发展,我们的项目可能会越来越复杂,... ...
分类:
其他好文 时间:
2020-03-03 15:04:11
阅读次数:
73
此题设快慢两个指针,先判断是否有环:如果为环快慢指针终会相遇; 找入口节点:快慢指针相遇的节点到入口节点的距离,与从头节点开始新的慢指针到相遇点的距离相同。 可画图演示。因为快指针是慢指针的两倍速,且他们在q点相遇,则我们可以得到等式 2(A+B) = A+B+C+B.得出C=A function ...
分类:
其他好文 时间:
2020-03-03 10:54:48
阅读次数:
61
LeetCode 142 链表 Linked List Cycle IILeetCodeGiven a linked list, return the node where the cycle begins. If there is no cycle, return null.To represen... ...
分类:
其他好文 时间:
2020-03-03 10:50:36
阅读次数:
56
协程: 使用一个线程来实现异步操作的。它相对于多线程执行效率高,不存在线程切换;此外协程不牵扯多线程中锁的机制,所以不必考虑加锁这些复杂操作。 协程是通过generator来实现的,就是yield关键字和send()函数的使用。 生成器的yield关键字: yield关键字可以将值(信息)返回,同时 ...
分类:
编程语言 时间:
2020-03-02 12:37:25
阅读次数:
81
1. 概述 Kafka是一个分布式、支持分区的、多副本的,基于zookeeper协调的分布式消息系统。 2. Kafka的特性 (1)高吞吐量、低延迟:Kafka每秒可以处理几十万条消息,它的延迟最低只有几毫秒,每个主题topic可以分为多个分区partition,消费者组consumer grou ...
分类:
其他好文 时间:
2020-03-01 19:38:00
阅读次数:
72
一、参考文档 https://community.atlassian.com/t5/Bitbucket-questions/Slow-SSH-clone-pull-push/qaq-p/953843 https://tech.jandou.com/to-accelerate-the-terminal ...
分类:
其他好文 时间:
2020-03-01 12:22:00
阅读次数:
313
问题项目使用spring-kafka操作消费kafka近期出现消费速度变慢,consumer消费一条数据平均需要200ms的时间,并且频繁发生,consumer会停止消费十几秒。日志分析以下为日志记录,consumer会时长从消费组中掉出再重新加入o.a.k.c.c.i.AbstractCoordinator:542-Markingthecoordinator127.0.0.1:9092(id:2
分类:
其他好文 时间:
2020-02-28 19:02:51
阅读次数:
461
set PATH=C:\Program Files\Java\jdk1.8.0_201\bin;@call kafka-consumer-groups.bat --bootstrap-server localhost:9092 --describe --group test-uat --comman ...
分类:
其他好文 时间:
2020-02-28 13:58:03
阅读次数:
59