kafka安装配置方法

万智汇安装助手app安卓版 6M / 简体中文

点击下载

Go安装器v4.9.7 18.79M / 简体中文

点击下载

暖通物联最新版(生活服务) v1.3.1 免费版 7.22M / 简体中文

点击下载

消息的发布称作producer，消息的订阅称作consumer，中间的存储阵列称作broker。kafka软件broker端不维护数据的消费状态，提升了性能，直接使用磁盘进行存储，线性读写，速度快：避免了数据在JVM内存和系统内存之间的复制，减少耗性能的创建对象和垃圾回收。kafka安装配置方法小编马上呈现！

kafka安装配置方法

环境配置

操作系统：Cent OS 7

Kafka版本：0.9.0.0

Kafka官网下载：请点击

JDK版本：1.7.0_51

SSH Secure Shell版本：XShell 5

Kafka目录介绍

/bin 操作kafka的可执行脚本，还包含windows下脚本

/config 配置文件所在目录

/libs 依赖库目录

/logs 日志数据目录，目录kafka把server端日志分为5种类型，分为:server,request,state，log-cleaner，controller

配置

配置zookeeper

请参考zookeeper

进入kafka安装工程根目录编辑config/server.properties

kafka最为重要三个配置依次为：broker.id、log.dir、zookeeper.connect，kafka server端config/server.properties参数说明和解释

启动Kafka

启动

进入kafka目录，敲入命令 bin/kafka-server-start.sh config/server.properties &

检测2181与9092端口

说明：

Kafka的进程ID为28094，占用端口为9092

QuorumPeerMain为对应的zookeeper实例，进程ID为19787，在2181端口监听

单机连通性测试

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

运行producer，随机敲入几个字符，相当于把这个敲入的字符消息发送给队列。

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

说明：早版本的Kafka，–broker-list 192.168.1.181:9092需改为–zookeeper 192.168.1.181:2181

运行consumer，可以看到刚才发送的消息列表。

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

注意：

producer，指定的Socket(192.168.1.181+9092),说明生产者的消息要发往kafka，也即是broker

consumer, 指定的Socket(192.168.1.181+2181),说明消费者的消息来自zookeeper（协调转发）

上面的只是一个单个的broker，下面我们来实验一个多broker的集群。

软件特别说明
kafka安装配置方法就在kafka专题里看看吧！