-
23.复制限流
复制限流 复制限流 在上一节中我们了解了分区重分配本质在于数据复制，先增加新的副本，然后进行数据同步，最后删除旧的副本来达到最终的目的。数据复制会占用额外的资源，如果重分配的量太大必然会严重影响整体的性能，尤其是处于业务高峰期的时候。减小重分配的粒度，以小批次的方式来操作是一种可行的解决思路。如果集群中某个主题或某个分区的流量在某段时间内特别大，那么... -
16.重要的消费者参数
重要的消费者参数 1. fetch.min.bytes 2. fetch.max.bytes 3. fetch.max.wait.ms 4. max.partition.fetch.bytes 5. max.poll.records 6. connections.max.idle.ms 7. exclude.internal.topics 8.... -
39. HTTP 基本格式？
📑 题目：39. HTTP 基本格式？ 参考解析 📑 题目：39. HTTP 基本格式？ 参考解析 ? HTTP 请求格式 HTTP 请求格式 请求行：用来说明请求类型，要访问的资源以及所使用的 HTTP 版本。 请求头部：紧接着请求行（即第一行）之后的部分，用来说明服务器要使用的附加信息从第二行起为请求头部。 HOST ，将... -
34.Kafka与Spark Streaming的整合
Spark Streaming简介 Kafka与Spark Streaming的整合 Spark Streaming简介 Spark Streaming 是 Spark 提供的对实时数据进行流式计算的组件。它是 Spark 核心 API 的一个扩展，具有吞吐量高、容错能力强的实时流数据处理系统，支持包括 Kafka、Flume、Kinesis 和 ... -
225. 用队列实现栈
🚀 本题 LeetCode 传送门 题目大意 题目要求用队列实现一个栈的基本操作：push(x)、pop()、top()、empty()。 解题思路 按照题目要求实现即可。 代码 package leetcode type MyStack struct { enque [] int deque [] ... -
34. UDP 报文的格式？
📑 题目：34. UDP 报文的格式？ 参考解析 📑 题目：34. UDP 报文的格式？ 参考解析 UDP 报文格式 16 位 * 4 = 64 位 = 8 字节。 -
90. 子集 II
📑 题目：90. 子集 II 📑 题目：90. 子集 II 🚀 本题 LeetCode 传送门 题目大意 给定一个可能包含重复元素的整数数组 nums，返回该数组所有可能的子集（幂集）。说明：解集不能包含重复的子集。 解题思路 这一题是第 78 题的加强版，比第 78 题多了一个条件，数组中的数字会出现重复。 解题方法依旧是 DFS，... -
32.Kafka监控（下）
消费滞后 监控指标说明 监控模块 总结 消费滞后 消息堆积是消息中间件的一大特色，消息中间件的流量削峰、冗余存储等功能正是得益于消息中间件的消息堆积能力。然而消息堆积是一把亦正亦邪的“双刃剑”，如果应用场合不恰当，反而会对上下游的业务造成不必要的麻烦，比如消息堆积势必会影响上下游整个调用链的时效性。在某些情况下，有些中间件如 RabbitMQ ... -
76. 最小覆盖子串
📑 题目：76. 最小覆盖子串 📑 题目：76. 最小覆盖子串 🚀 本题 LeetCode 传送门 题目大意 给定一个源字符串 s，再给一个字符串 T，要求在源字符串中找到一个窗口，这个窗口包含由字符串各种排列组合组成的，窗口中可以包含 T 中没有的字符，如果存在多个，在结果中输出最小的窗口，如果找不到这样的窗口，输出空字符串。 解题思路 ... -
124.榜单如何实现，击杀数降序排、死亡数升序排多个维度一个redis zset如何处理
方案步骤 实现步骤 解释 注意事项 在 Redis 中实现一个排行榜，并且同时考虑多个维度（如击杀数降序和死亡数升序）来排序，可以使用 Redis 的 ZSET 结合自定义的评分计算方法。我们需要将每个玩家的击杀数和死亡数结合起来计算一个综合分数，然后使用这个分数在 Redis 的有序集合中进行排序。 方案步骤 定义评分计算方法 ：我们需...