linux 安装 kafka&zookeeper

时间:2022-05-22 22:10:19

安装kafka

1,下载kafka.

#cd /usr/local

#wget wget https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.1.1/kafka_2.11-2.1.1.tgz

解压安装包

#tar -zxvf kafka_2.11-2.1.1.tgz

更改安装包的名称。

# mv kafka_2.11-2.1.1 kafka

linux 安装  kafka&zookeeper

2,配置kafka。

创建log文件夹。

#cd /usr/local/kafka

# mkdir -pv /usr/local/kafka/log/kafka

修改/usr/local/kafka/config/目录下的配置文件

# vi /usr/local/kafka/config/server.properties

port=9092 #端口号
log.dirs=/usr/local/kafka/log/kafka #日志存放路径,上面创建的目录

linux 安装  kafka&zookeeper

linux 安装  kafka&zookeeper

3,配置kafka允许客户端可以远程连接。

把listeners=PLAINTEXT://:9092的注释去掉

把#advertised.listeners=PLAINTEXT://your.host.name:9092的注释也去掉,同时修改自己正确的IP地址,如 advertised.listeners=PLAINTEXT://52.82.102.211:9092

linux 安装  kafka&zookeeper

配置zookeeper:
mkdir /usr/local/kafka/zookeeper    #创建zookeeper目录

mkdir /usr/local/kafka/log/zookeeper  #创建zookeeper日志目录

cd /usr/local/kafka/config           #进入配置目录

vi zookeeper.properties          #编辑修改相应的参数

dataDir=/usr/local/kafka/zookeeper #zookeeper数据目录

dataLogDir=/usr/local/kafka/log/zookeeper #zookeeper日志目录

clientPort=2181

maxClientCnxns=100

tickTime=2000

initLimit=10

syncLimit=5

:wq! #保存退出

linux 安装  kafka&zookeeper

4,启动服务。

需要以守护进程方式运行(加了-daemon),不然关闭终端后kafka和zookeeper自动停止。

#/usr/local/kafka/bin/zookeeper-server-start.sh -daemon /usr/local/kafka/config/zookeeper.properties

#/usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties

linux 安装  kafka&zookeeper

关闭服务。

#/usr/local/kafka/bin/zookeeper-server-stop.sh /usr/local/kafka/config/zookeeper.properties

#/usr/local/kafka/bin/kafka-server-stop.sh /usr/local/kafka/config/server.properties

如果还是无法停止服务,使用kill -9

linux 安装 kafka&zookeeper的更多相关文章

  1. 安装kafka + zookeeper集群

    系统:centos 7.4 要求:jdk :1.8.x kafka_2.11-1.1.0 1.绑定/etc/hosts 10.10.10.xxx      online-ops-xxx-0110.10 ...

  2. Linux 安装 Kafka

    1. 下载安装包 官网下载地址:http://kafka.apache.org/downloads 选择一个版本下载,然后解压安装包. 2. 基本使用 2.1 启动kafka bin/zookeepe ...

  3. linux 安装配置zookeeper

    1.什么是zookeeper ZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,是Google的Chubby一个开源的实现,是Hadoop和Hbase的重要组件.它是一个为分布式应用 ...

  4. linux 安装redis zookeeper

    安装redis: http://www.redis.cn/download.html 安装的前提条件: 需要安装gcc:yum install gcc-c++ wget http://download ...

  5. linux 安装配置zookeeper脚本

    #!/bin/bash # automatic install zookeeper echo "========= Start to install zookeeper ========== ...

  6. linux 安装dubbo+zookeeper

    dubbo+zookeeper 启动成功 注意:dubbo-admin-2.5.4 不支持java8

  7. Linux安装Kafka

    https://blog.csdn.net/qq_33257527/article/details/85227478 https://jingyan.baidu.com/article/36d6ed1 ...

  8. Linux下Kafka单机安装配置方法(图文)

    Kafka是一个分布式的.可分区的.可复制的消息系统.它提供了普通消息系统的功能,但具有自己独特的设计.这个独特的设计是什么样的呢 介绍 Kafka是一个分布式的.可分区的.可复制的消息系统.它提供了 ...

  9. Linux下Kafka单机安装配置方法

    Kafka是一个分布式的.可分区的.可复制的消息系统.它提供了普通消息系统的功能,但具有自己独特的设计.这个独特的设计是什么样的呢? 首先让我们看几个基本的消息系统术语: •Kafka将消息以topi ...

随机推荐

  1. Bootstrap之字体图标

    优点:1.减少请求 2.容易控制样式 所在位置:在下载的bootstrap文件中的fonts文件夹存放字体图标 默认路径为当前目录下,如需修改路径,则需在bootstrap.css中查找font-fa ...

  2. Brackets前端开发IDE工具

    Brackets是一个开源的前端开发IDE工具,网页设计师和前端开发人员必备的前端开发IDE工具. 它能够使你在开发WEB网站实时预览你的网页,目前版本只适用于Chrome浏览器可以实时预览效果 支持 ...

  3. 数据摘要算法的测试效率(SHA、MD5和CRC32)

    1.算法概述 数据摘要算法是密码学算法中非常重要的一个分支,它通过对所有数据提取指纹信息以实现数据签名.数据完整性校验等功能,由于其不可逆性,有时候会被用做敏感信息的加密.数据摘要算法也被称为哈希(H ...

  4. Java中堆和栈创建对象的区别

    http://blog.csdn.net/hbhhww/article/details/8152838

  5. Javac和java命令执行java程序

    javac [ options ] [ sourcefiles ] [ @files ]:编译一个java文件. 1. 注意到执行命令必须要指定到包含java文件的路径,否则会出现找不到file错误. ...

  6. POJ - 3984 bfs [kuangbin带你飞]专题一

    bfs搜索过程中将路径保存下即可. AC代码 #include<cstdio> #include<cstring> #include<algorithm> #inc ...

  7. SpringBoot2&period;x开发案例之整合Quartz任务管理系统

    基于spring-boot 2.x + quartz 的CRUD任务管理系统,适用于中小项目. 基于spring-boot +quartz 的CRUD任务管理系统: https://gitee.com ...

  8. H5 26-CSS三大特性之优先级

    26-CSS三大特性之优先级 类>标签>通配符>继承>浏览器默认 --> 0 我是段落 <!DOCTYPE html> <html lang=&quot ...

  9. 解释局域(LAN)和广域网(WAN)之间的区别,它们之间的关系是什么?

    解释局域(LAN)和广域网(WAN)之间的区别,它们之间的关系是什么?

  10. System&period;exit&lpar;0&rpar;会跳过finally块的执行

    public class test { public static void main(String[] args) { try { System.exit(0); System.out.printl ...