淘先锋技术网

首页 1 2 3 4 5 6 7

kafka安装配置使用

一、环境配置

1、所需环境：

  • 操作系统：Ubuntu 14
  • Kafka版本：2.0.1
  • Kafka官网下载：请点击
  • JDK版本：1.8.0_221-b11
  • SSH Secure Shell：SecureCRT

二、安装部署

1、安装JDK

在JDK官网对应系统安装包。

Linux环境对应

（1）解压安装包： 

tar -zxvf jdk-8u221-linux-x64.tar.gz

（2）配置环境变量

将解压后的文件放入 /usr/java 中

配置环境变量：

vi /etc/profile

在末尾加入以下代码：

export JAVA_HOME=/usr/java/jdk1.8.0_221 #根据你的版本号更改
export JRE_HOME=${JAVA_HOME}/jre
export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib:$CLASSPATH
export JAVA_PATH=${JAVA_HOME}/bin:${JRE_HOME}/bin
export PATH=$PATH:${JAVA_PATH}

（3）测试安装成功

直接输入：javac  和 java -version  有内容则安装成功。

2、下载安装kafka

在apche官网下载对应的kafuka版本。

注意：不要下载源码

下载Scala版本

（1）解压安装包

tar -zxvf kafka_2.11-2.0.1.tgz

对应将解压后的文件放到 /usr/kafka中。

（2）启动kafka

进入kafka目录文件，按顺序运行下面代码

bin/zookeeper-server-start.sh config/zookeeper.properties & #启动zookeeper（&是为了能退出命令行）

bin/kafka-server-start.sh config/server.properties &  #启动kafka

（3）查看程序是否启动

使用netstat -nultp 命令，查看是否有9092和2181端口被占用，启动成功则会被占用。

（4）联通性测试

启动2个CRT客户端，一个用于生产者发送消息，一个用于消费者接受消息。

运行producer：

    bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

运行consumer：

    bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

最后就可以在producer中发送消息，consumer中能收到消息：