-
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 ... -
17.主题与分区
主题与分区 主题的管理 创建主题 主题与分区 主题和分区是 Kafka 的两个核心概念，前面章节中讲述的生产者和消费者的设计理念所针对的都是主题和分区层面的操作。主题作为消息的归类，可以再细分为一个或多个分区，分区也可以看作对消息的二次归类。分区的划分不仅为 Kafka 提供了可伸缩性、水平扩展的功能，还通过多副本机制来为 Kafka 提供数据冗...