-
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 ，将... -
128. 最长连续序列
📑 题目：128. 最长连续序列 📑 题目：128. 最长连续序列 🚀 本题 LeetCode 传送门 题目大意 给定一个未排序的整数数组，找出最长连续序列的长度。要求算法的时间复杂度为 O(n)。 解题思路 给出一个数组，要求找出最长连续序列，输出这个最长的长度。要求时间复杂度为 O(n) 。 这一题可以先用暴力解决解决，代码见解法... -
9. 反序列化
反序列化 反序列化 在第4节中我们讲述了 KafkaProducer 对应的序列化器，那么与此对应的 KafkaConsumer 就会有反序列化器。Kafka 所提供的反序列化器有 ByteBufferDeserializer、ByteArrayDeserializer、BytesDeserializer、DoubleDeserializer、Flo... -
125. 验证回文串
📑 题目：125. 验证回文串 📑 题目：125. 验证回文串 🚀 本题 LeetCode 传送门 题目大意 判断所给的字符串是否是有效的回文串。 解题思路 简单题，按照题意做即可。 代码 package leetcode import ( "strings" ) func isPalindrom... -
30.Kafka Streams
Kafka Streams Kafka Streams Kafka 一直被认为是一个强大的消息中间件，它实现了高吞吐、高可用和低延时的消息传输能力，这让它成为流式处理系统中完美的数据来源。目前通用的一些流式处理框架如 Apache Spark、Apache Flink、Apache Storm 等都可以将 Kafka 作为可靠的数据来源。但遗憾的是，... -
28.Kafka Connect
Kafka Connect 独立模式 REST API 分布式模式 Kafka Connect Kafka Connect 是一个工具，它为在 Kafka 和外部数据存储系统之间移动数据提供了一种可靠的且可伸缩的实现方式。Kafka Connect 可以简单快捷地将数据从 Kafka 中导入或导出，数据范围涵盖关系型数据库、日志和度量数据、Ha... -
67. 二进制求和
📑 题目：67. 二进制求和 📑 题目：67. 二进制求和 🚀 本题 LeetCode 传送门 题目大意 给你两个二进制字符串，返回它们的和（用二进制表示）。输入为 非空 字符串且只包含数字 1 和 0。 解题思路 要求输出 2 个二进制数的和，结果也用二进制表示。 简单题。按照二进制的加法规则做加法即可。 代码 package... -
111. 二叉树的最小深度
📑 题目：111. 二叉树的最小深度 📑 题目：111. 二叉树的最小深度 🚀 本题 LeetCode 传送门 题目大意 给定一个二叉树，找出其最小深度。最小深度是从根节点到最近叶子节点的最短路径上的节点数量。说明: 叶子节点是指没有子节点的节点。 解题思路 递归求出根节点到叶子节点的深度，输出最小值即可 代码 package ...