1.关于为什么要阅读Kafka源码？ 其实日常生产中，我们不会接触很复杂的kafka代码，都是一些比较简单的生产者消费者代码，那为什么还是要学习Kafka源码呢？学习Kafka源码的好处是我们在日常使用Kafka的过程，不可避免的会遇到一些关于Kafka的一些bug和问题，比方说一些参数配置问题，这个时候如果
记录一次vmware 中，物理机与nat模式的虚拟机通讯https://blog.csdn.net/qq_31329893/article/details/83511815 事情起因是因为我做老男孩的openstack实验，规划是openstack-controller======》主机名按要求是controller ip是10.0.0.11/24 gw是10.0.0.2 openstack-compute1===
nginx 负载均衡的配置 1、最基本的 轮询 有可能出现机器的性能没有充分发挥。 upstream linuxidc { server 10.0.6.108:7080; server 10.0.0.85:8980; } location / { proxy_pass http://linuxidc; } 2、权重方式 人为根据计
一、单台kafka安装 1、下载kafka安装包kafka_2.11-0.11.0.2.tgz到集群的某台节点上(hadoop1) 2、将按照包远程传输到节点hadoop2、hadoop3上 scp -r kafka_2.11-0.11.0.2.tgz root@hadoop2:`pwd` scp -r kafka_2.11-0.11.0.2.tgz root@hadoop3:`pwd` 3、解压安装包 tar -zxvf kaf
本文略过haproxy安装和基本配置主要写一下haproxy根据不同不路径访问不同集群本文架构如图，集群A和集群B就先用一台web服务器代替 利用ACL匹配访问路径,访问192.168.0.11/a,和192.168.0.11/b时返回不同集群的内容，配置如下 listen webbind 192.168.0.11:80mode httpacl static_path_
kafka是大数据组件中的消息队列，俗语有云：系统卡不卡，全看kafka。kafka的使用能极大的提升的系统吞吐量。本文将阐述在CentOS7中安装kafka。 1 系统、软件以及前提约束 CentOS 7 64 工作站 作者的机子ip是192.168.100.200，请读者根据自己实际情况设置 jdk1.8.0_162 已经安装完毕，并配
实验环境：信号量的实现和应用 实验任务： 在 Ubuntu 下编写程序，用信号量解决生产者——消费者问题； 在 linux-0.11 中实现信号量，用生产者—消费者程序检验之。 用信号量解决生产者—消费者问题 实验要求：pc.c程序需打开一个文件buffer.txt作为共享缓冲区，缓冲区同时最多只能保
1 概述 目前我们部分系统还在使用Kafka0.8.2.2 的版本。 0.8.2.2版本发行于2014年10月28号，距今已经过去4年多的时间。 三年的时间，Kafka截至到（2018-02-28），已经累计发布了14个版本，最新版本为1.0.0，由此，0.8.2已经远远落后于Kafka的最新版本14个版本，很多新特性和功能比新版本
在Linux上我一直使用nvm来管理nodejs的不同版本，但是nvm没有windows版本，今天发现在windows上可以使用另外一个版本管理工具nvm-windows来管理。 下载与安装下载地址：https://github.com/coreybutler/nvm-windows/releases 安装前，这里有一点需要注意，如果以前安装过node，需要先卸载，并且
1、安装jdk1.8 2、安装ZooKeeper 1、 下载安装包（附带链接） 2、 解压并进入ZooKeeper目录，笔者：D:\Kafka\zookeeper-3.4.9\conf 3、 将“zoo_sample.cfg”重命名为“zoo.cfg” 4、 打开“zoo.cfg”找到并编辑dataDir=D:\Kafka\zookeeper-3.4.9\data 5、 添加系统变量：ZOOKEEPER_HOM
1、下载地址：https://repo1.maven.org/maven2/com/github/dreamhead/moco-runner/0.11.0/ 下载：moco-runner-0.11.0-standalone.jar 2、moco启动实例： 在项目上创建目录moco,拷贝下载好的jar包到新建目录，新建mock文件startup.json： mock文件实例 cd命令切换到新建目录：
相关环境依赖 安装系统环境： CentOS7.6 git软件： 1.8 mysql： 5.7 gogs 用户git 一下安装都安装在/home/git/下面 创建系统用户git： sudo useradd git /etc/sudoers 文件加 git ALL=(ALL) NOPASSWD:ALL /etc/sudoers 这个文件是可读的，修改前先增加可写权限 gogs 安装 su gi
ZooKeeper是一个为分布式应用所设计的分布的、开源的协调服务，它主要是用来解决分布式应用中经常遇到的一些数据管理问题，简化分布式应用协调及其管理的难度，提供高性能的分布式服务。ZooKeeper本身可以以Standalone模式安装运行，不过它的长处在于通过分布式ZooKeeper集群（一
HDFS正常启动 zookeeper正常安装 sw目录下的KAFKA解压安装 tar zxvf kafka_2.11-0.11.0.2.tgz mv kafka_2.11-0.11.0.2 ../md/ 配置环境变量 vi ~/.bash_profile export KAFKA_HOME=/home/a/md/kafka_2.11-0.11.0.2 export PATH=$KAFKA_HOME/bin:$PATH source ~/.bash_profile
