官方中文文档:https://kafka.apachecn.org/quickstart.html 1 下载安装包&解压缩 下载地址:http://kafka.apache.org 解压缩命令**(根据实际情况选择解压路径)**: tar -zxvf kafka_2.11-1.0.1.tgz -C ...
分类:
其他好文 时间:
2021-06-19 19:05:25
阅读次数:
0
BOOL IsFolderEmpty(string path) { string str = path + "\\*.*"; CFileFind ff; BOOL bFound; bFound = ff.FindFile(str.c_str()); while (bFound) { bFound = ...
分类:
编程语言 时间:
2021-06-19 18:41:36
阅读次数:
0
1. 前言 Slice又称动态数组,依托数组实现,可以方便的进行扩容、传递等,实际使用中比数组更灵活。 正因为灵活,如果不了解其内部实现机制,有可能遭遇莫名的异常现象。Slice的实现原理很简单,本节试图根据真实的使用场景,在源码中总结实现原理。 2 Slice实现原理 Slice依托数组实现,底层 ...
分类:
其他好文 时间:
2021-06-18 19:20:04
阅读次数:
0
df -h pvdisplay vgdisplay fdisk -l 查看新加卷在新磁盘创建物理卷pvcreate /dev/sdb将新磁盘添加到物理卷组vgextend rootvg /dev/sdb扩容lvmlvextend -L +2000G /dev/mapper/rootvg-rootlv ...
分类:
其他好文 时间:
2021-06-18 19:08:09
阅读次数:
0
kafka几圈搭建好了,但当一个节点挂机后整个集群还是不能使用并没有起到集群的作用,这是为什么? 在新版本Kafka中,__consumer_offsets这个topic是存放消费者偏移量的,但是该主题默认配置副本数量只有1,容易造成单点故障 注:上一篇博客地址https://www.cnblogs ...
分类:
其他好文 时间:
2021-06-18 18:52:34
阅读次数:
0
打开题目 是一串代码 1 <?php 2 extract($_GET); 3 if (!empty($ac)) 4 { 5 $f = trim(file_get_contents($fn)); 6 if ($ac $f) 7 { 8 echo "<p>This is flag:" ." $flag< ...
分类:
其他好文 时间:
2021-06-17 16:32:24
阅读次数:
0
题目链接:https://leetcode-cn.com/problems/ti-huan-kong-ge-lcof/ 题目描述: 题解: 空间复杂度:O(1) 1.先找出字符串中含有多少个空格 2.对原字符串空间扩容 3.定义两个指针,一个指向新字符串的末尾,一个指向原始字符串的末尾 class ...
分类:
其他好文 时间:
2021-06-16 18:33:53
阅读次数:
0
系列文章目录 https://zhuanlan.zhihu.com/p/367683572 (文章目录) 一. 业务模型 在上一篇文章中,我们分析了生产者的原理。下一步我们来分析下提交上来的消息在Server端时如何存储的。 1.1 概念梳理 Kafka用Topic将数据划分成内聚性较强的子集,To ...
分类:
其他好文 时间:
2021-06-15 17:59:49
阅读次数:
0
1、说明 编写完ROS的hello world程序后,基本可以了解ROS的功能包开发的流程,现在再编写一个节点通信的测试代码,使用 topic 模式,即发布-订阅者模式,且传递的消息是自定义类型 上代码 2、创建工作空间 该例不再创建新的工作空间,和hello world示例共用一个 3、创建功能包 ...
分类:
其他好文 时间:
2021-06-15 17:57:06
阅读次数:
0
在消息RabbitMQ时,我们关心的一个问题是手动ack还是自动ack,如果是自动ack就怕出现丢消息的情况 Flink以RabbitMQ作为Source,是怎么保证消息唯一性的呢,是怎么保证ack的. 首先引入依赖包 <dependency> <groupId>org.apache.flink</ ...
分类:
其他好文 时间:
2021-06-11 19:15:45
阅读次数:
0