码迷,mamicode.com
首页 >  
搜索关键字:kafka 扩容 topic empty    ( 15636个结果
Kafka使用备忘
官方中文文档: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
mfc判断目录是否为空
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
slice数据结构
1. 前言 Slice又称动态数组,依托数组实现,可以方便的进行扩容、传递等,实际使用中比数组更灵活。 正因为灵活,如果不了解其内部实现机制,有可能遭遇莫名的异常现象。Slice的实现原理很简单,本节试图根据真实的使用场景,在源码中总结实现原理。 2 Slice实现原理 Slice依托数组实现,底层 ...
分类:其他好文   时间:2021-06-18 19:20:04    阅读次数:0
centos7 lvm添加硬盘后扩展磁盘空间
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集群五、__consumer_offsets副本数修改
kafka几圈搭建好了,但当一个节点挂机后整个集群还是不能使用并没有起到集群的作用,这是为什么? 在新版本Kafka中,__consumer_offsets这个topic是存放消费者偏移量的,但是该主题默认配置副本数量只有1,容易造成单点故障 注:上一篇博客地址https://www.cnblogs ...
分类:其他好文   时间:2021-06-18 18:52:34    阅读次数:0
bugku-file_get_contents
打开题目 是一串代码 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
Kafka源码分析(三) - Server端 - 消息存储
系列文章目录 https://zhuanlan.zhihu.com/p/367683572 (文章目录) 一. 业务模型 在上一篇文章中,我们分析了生产者的原理。下一步我们来分析下提交上来的消息在Server端时如何存储的。 1.1 概念梳理 Kafka用Topic将数据划分成内聚性较强的子集,To ...
分类:其他好文   时间:2021-06-15 17:59:49    阅读次数:0
ROS节点通信(一)消息发布和订阅
1、说明 编写完ROS的hello world程序后,基本可以了解ROS的功能包开发的流程,现在再编写一个节点通信的测试代码,使用 topic 模式,即发布-订阅者模式,且传递的消息是自定义类型 上代码 2、创建工作空间 该例不再创建新的工作空间,和hello world示例共用一个 3、创建功能包 ...
分类:其他好文   时间:2021-06-15 17:57:06    阅读次数:0
Flink 消费RabbitMQ 和 Kafka
在消息RabbitMQ时,我们关心的一个问题是手动ack还是自动ack,如果是自动ack就怕出现丢消息的情况 Flink以RabbitMQ作为Source,是怎么保证消息唯一性的呢,是怎么保证ack的. 首先引入依赖包 <dependency> <groupId>org.apache.flink</ ...
分类:其他好文   时间:2021-06-11 19:15:45    阅读次数:0
15636条   上一页 1 ... 3 4 5 6 7 ... 1564 下一页
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!